org.springframework.messaging.simp.stomp

Class Reactor11StompCodec

java.lang.Object

org.springframework.messaging.simp.stomp.Reactor11StompCodec

All Implemented Interfaces:

reactor.io.encoding.Codec<reactor.io.Buffer,Message<byte[]>,Message<byte[]>>

public class Reactor11StompCodec
extends java.lang.Object
implements reactor.io.encoding.Codec<reactor.io.Buffer,Message<byte[]>,Message<byte[]>>

A Reactor TCP Codec for sending and receiving STOMP messages.

Since:

4.0

Author:

Andy Wilkinson, Rossen Stoyanchev

Constructor Summary

Constructors

Constructor and Description
Reactor11StompCodec()
Reactor11StompCodec(StompEncoder encoder, StompDecoder decoder)

Method Summary

Modifier and Type	Method and Description
reactor.function.Function<reactor.io.Buffer,Message<byte[]>>	decoder(reactor.function.Consumer<Message<byte[]>> messageConsumer)
reactor.function.Function<Message<byte[]>,reactor.io.Buffer>	encoder()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Reactor11StompCodec

public Reactor11StompCodec()

Reactor11StompCodec

public Reactor11StompCodec(StompEncoder encoder,
                           StompDecoder decoder)

Method Detail

decoder

public reactor.function.Function<reactor.io.Buffer,Message<byte[]>> decoder(reactor.function.Consumer<Message<byte[]>> messageConsumer)

Specified by:

decoder in interface reactor.io.encoding.Codec<reactor.io.Buffer,Message<byte[]>,Message<byte[]>>

encoder

public reactor.function.Function<Message<byte[]>,reactor.io.Buffer> encoder()

Specified by:

encoder in interface reactor.io.encoding.Codec<reactor.io.Buffer,Message<byte[]>,Message<byte[]>>