Package org.springframework.messaging.simp.stomp

Class Reactor2StompCodec

  • All Implemented Interfaces:
    reactor.fn.Function<Message<byte[]>,​reactor.io.buffer.Buffer>
    public class Reactor2StompCodec
extends reactor.io.codec.Codec<reactor.io.buffer.Buffer,​Message<byte[]>,​Message<byte[]>>
    A Reactor TCP Codec for sending and receiving STOMP messages.
    Since:
    4.0
    Author:
    Andy Wilkinson, Rossen Stoyanchev

    • Method Detail

      • decoder

        public reactor.fn.Function<reactor.io.buffer.Buffer,​Message<byte[]>> decoder​(reactor.fn.Consumer<Message<byte[]>> messageConsumer)
        Specified by:
        decoder in class reactor.io.codec.Codec<reactor.io.buffer.Buffer,​Message<byte[]>,​Message<byte[]>>

      • encoder

        public reactor.fn.Function<Message<byte[]>,​reactor.io.buffer.Buffer> encoder()
        Overrides:
        encoder in class reactor.io.codec.Codec<reactor.io.buffer.Buffer,​Message<byte[]>,​Message<byte[]>>

      • apply

        public reactor.io.buffer.Buffer apply​(Message<byte[]> message)