public class Reactor2StompCodec
extends <any>
Codec
for sending and receiving STOMP messages.Modifier and Type | Class and Description |
---|---|
private static class |
Reactor2StompCodec.DecodingFunction |
private static class |
Reactor2StompCodec.EncodingFunction |
Modifier and Type | Field and Description |
---|---|
private <any> |
encodingFunction |
private StompDecoder |
stompDecoder |
private StompEncoder |
stompEncoder |
Constructor and Description |
---|
Reactor2StompCodec() |
Reactor2StompCodec(StompEncoder encoder,
StompDecoder decoder) |
Modifier and Type | Method and Description |
---|---|
Buffer |
apply(Message<byte[]> message) |
<any> |
decoder(<any> messageConsumer) |
<any> |
encoder() |
private final StompDecoder stompDecoder
private final StompEncoder stompEncoder
private final <any> encodingFunction
public Reactor2StompCodec()
public Reactor2StompCodec(StompEncoder encoder, StompDecoder decoder)
public <any> decoder(<any> messageConsumer)
public <any> encoder()
public Buffer apply(Message<byte[]> message)