org.springframework.messaging.simp.stomp

Class Reactor2StompCodec

java.lang.Object

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

org.springframework.messaging.simp.stomp.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

Field Summary

Fields inherited from class reactor.io.codec.Codec

DEFAULT_DELIMITER, delimiter

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class reactor.io.codec.Codec

addDelimiterIfAny, decode, decoder, doBufferDecode, doDelimitedBufferDecode, encode, invokeCallbackOrReturn

Methods inherited from class java.lang.Object

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

Constructor Detail

Reactor2StompCodec

public Reactor2StompCodec()

Reactor2StompCodec

public Reactor2StompCodec(StompEncoder encoder,
                          StompDecoder decoder)

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)