org.springframework.messaging.simp.stomp

Class StompCodec

java.lang.Object

org.springframework.messaging.simp.stomp.StompCodec

All Implemented Interfaces:

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

public class StompCodec
extends Object
implements reactor.tcp.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

Constructor Summary

Constructors

Constructor and Description
StompCodec()

Method Summary

Modifier and Type	Method and Description
reactor.function.Function<reactor.io.Buffer,Message<byte[]>>	decoder(reactor.function.Consumer<Message<byte[]>> next)
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

StompCodec

public StompCodec()

Method Detail

decoder

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

Specified by:

decoder in interface reactor.tcp.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.tcp.encoding.Codec<reactor.io.Buffer,Message<byte[]>,Message<byte[]>>