org.springframework.messaging.tcp.reactor

Class ReactorNettyTcpClient.StompMessageDecoder<P>

java.lang.Object

ByteToMessageDecoder

org.springframework.messaging.tcp.reactor.ReactorNettyTcpClient.StompMessageDecoder<P>

Enclosing class:

ReactorNettyTcpClient<P>

private static class ReactorNettyTcpClient.StompMessageDecoder<P>
extends ByteToMessageDecoder

Field Summary

Fields

Modifier and Type	Field and Description
private ReactorNettyCodec<P>	codec

Constructor Summary

Constructors

Constructor and Description
StompMessageDecoder(ReactorNettyCodec<P> codec)

Method Summary

Modifier and Type	Method and Description
protected void	decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out)

Methods inherited from class java.lang.Object

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

Field Detail

codec

private final ReactorNettyCodec<P> codec

Constructor Detail

StompMessageDecoder

public StompMessageDecoder(ReactorNettyCodec<P> codec)

Method Detail

decode

protected void decode(ChannelHandlerContext ctx,
                      ByteBuf in,
                      java.util.List<java.lang.Object> out)
               throws java.lang.Exception

Throws:

java.lang.Exception