程序包 org.springframework.messaging.simp.stomp

类 Reactor2StompCodec

  • 所有已实现的接口:
    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.
    从以下版本开始:
    4.0
    作者:
    Andy Wilkinson, Rossen Stoyanchev

    • 方法详细资料

      • decoder

        public reactor.fn.Function<reactor.io.buffer.Buffer,​Message<byte[]>> decoder​(reactor.fn.Consumer<Message<byte[]>> messageConsumer)
        指定者:
        decoder 在类中 reactor.io.codec.Codec<reactor.io.buffer.Buffer,​Message<byte[]>,​Message<byte[]>>

      • encoder

        public reactor.fn.Function<Message<byte[]>,​reactor.io.buffer.Buffer> encoder()
        覆盖:
        encoder 在类中 reactor.io.codec.Codec<reactor.io.buffer.Buffer,​Message<byte[]>,​Message<byte[]>>

      • apply

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