org.springframework.messaging.simp.stomp

Class Reactor2StompCodec

java.lang.Object

<any>

org.springframework.messaging.simp.stomp.Reactor2StompCodec

public class Reactor2StompCodec
extends <any>

A Reactor TCP Codec for sending and receiving STOMP messages.

Since:

4.0

Author:

Andy Wilkinson, Rossen Stoyanchev

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	Reactor2StompCodec.DecodingFunction
private static class	Reactor2StompCodec.EncodingFunction

Field Summary

Fields

Modifier and Type	Field and Description
private <any>	encodingFunction
private StompDecoder	stompDecoder
private StompEncoder	stompEncoder

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Buffer	apply(Message<byte[]> message)
<any>	decoder(<any> messageConsumer)
<any>	encoder()

Methods inherited from class java.lang.Object

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

Field Detail

stompDecoder

private final StompDecoder stompDecoder

stompEncoder

private final StompEncoder stompEncoder

encodingFunction

private final <any> encodingFunction

Constructor Detail

Reactor2StompCodec

public Reactor2StompCodec()

Reactor2StompCodec

public Reactor2StompCodec(StompEncoder encoder,
                          StompDecoder decoder)

Method Detail

decoder

public <any> decoder(<any> messageConsumer)

encoder

public <any> encoder()

apply

public Buffer apply(Message<byte[]> message)