Package org.springframework.messaging.simp.stomp

Class StompTcpMessageCodec

java.lang.Object

org.springframework.messaging.simp.stomp.StompTcpMessageCodec

All Implemented Interfaces:

TcpMessageCodec<byte[]>

public class StompTcpMessageCodec
extends Object
implements TcpMessageCodec<byte[]>

TcpMessageCodec for STOMP, delegating to StompDecoder and StompEncoder.

Since:

6.0

Author:

Rossen Stoyanchev

Constructor Summary

Constructors

Constructor	Description
StompTcpMessageCodec()
StompTcpMessageCodec(StompDecoder decoder)
StompTcpMessageCodec(StompDecoder decoder, StompEncoder encoder)

Method Summary

Modifier and Type	Method	Description
List<Message<byte[]>>	decode(ByteBuffer nioBuffer)	Decode the input ByteBuffer into one or more Messages.
ByteBuffer	encode(Message<byte[]> message)	Encode the given Message to the output ByteBuffer.

Methods inherited from class java.lang.Object

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

Constructor Details

StompTcpMessageCodec

public StompTcpMessageCodec()

StompTcpMessageCodec

public StompTcpMessageCodec(StompDecoder decoder)

StompTcpMessageCodec

public StompTcpMessageCodec(StompDecoder decoder,
 StompEncoder encoder)

Method Details

decode

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

Description copied from interface: TcpMessageCodec

Decode the input ByteBuffer into one or more Messages.

Specified by:

decode in interface TcpMessageCodec<byte[]>

Parameters:

nioBuffer - the input buffer to decode from

Returns:

0 or more decoded messages

encode

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

Description copied from interface: TcpMessageCodec

Encode the given Message to the output ByteBuffer.

Specified by:

encode in interface TcpMessageCodec<byte[]>

Parameters:

message - the message to encode

Returns:

the encoded buffer