public Class StompTcpMessageCodec

Class Inheritance

extends Object
implements TcpMessageCodec<byte[]>

All Implemented Interfaces

org.springframework.messaging.tcp.reactor.TcpMessageCodec

Imports

TcpMessageCodec for STOMP, delegating to StompDecoder and StompEncoder.

Field Summary

Modifier and Type	Field and Description
private final StompDecoder	decoder
private final StompEncoder	encoder

Access	Constructor and Description
public	StompTcpMessageCodec()
public	StompTcpMessageCodec(StompDecoder decoder)
public	StompTcpMessageCodec(StompDecoder decoder, StompEncoder encoder)

Modifier and Type	Method and Description
public List<Message<byte[]>>	decode(ByteBuffer the input buffer to decode from nioBuffer) Implements org.springframework.messaging.tcp.reactor.TcpMessageCodec.decode. Decode the input `ByteBuffer` into one or more `Messages`.
public ByteBuffer	encode(Message<byte[]> the message to encode message) Implements org.springframework.messaging.tcp.reactor.TcpMessageCodec.encode. Encode the given `Message` to the output `ByteBuffer`.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

decoder	back to summary
private final StompDecoder decoder

encoder	back to summary
private final StompEncoder encoder

StompTcpMessageCodec	back to summary
public StompTcpMessageCodec()

StompTcpMessageCodec	back to summary
public StompTcpMessageCodec(StompDecoder decoder)

StompTcpMessageCodec	back to summary
public StompTcpMessageCodec(StompDecoder decoder, StompEncoder encoder)

decode back to summary

decode	back to summary
public List<Message<byte[]>> decode(ByteBuffer nioBuffer) Implements org.springframework.messaging.tcp.reactor.TcpMessageCodec.decode. Doc from org.springframework.messaging.tcp.reactor.TcpMessageCodec.decode. Decode the input `ByteBuffer` into one or more `Messages`. Parameters nioBuffer:ByteBuffer the input buffer to decode from Returns:List<Message<byte[]>> 0 or more decoded messages Annotations @Override

public List<Message<byte[]>> decode(ByteBuffer nioBuffer)

Decode the input ByteBuffer into one or more Messages.

Parameters

Returns:List<Message<byte[]>>

0 or more decoded messages

Annotations

encode back to summary

encode	back to summary
public ByteBuffer encode(Message<byte[]> message) Implements org.springframework.messaging.tcp.reactor.TcpMessageCodec.encode. Doc from org.springframework.messaging.tcp.reactor.TcpMessageCodec.encode. Encode the given `Message` to the output `ByteBuffer`. Parameters message:Message<byte[]> the message to encode Returns:ByteBuffer the encoded buffer Annotations @Override

public ByteBuffer encode(Message<byte[]> message)

Encode the given Message to the output ByteBuffer.

Parameters

the encoded buffer

Annotations