public class SctpOutboundByteStreamHandler extends MessageToMessageEncoder<ByteBuf>
ByteBuf
to SctpMessage
and send it through a specific stream
with given protocol identifier.ChannelHandler.Sharable, ChannelHandler.Skip
Constructor and Description |
---|
SctpOutboundByteStreamHandler(int streamIdentifier,
int protocolIdentifier) |
Modifier and Type | Method and Description |
---|---|
protected void |
encode(ChannelHandlerContext ctx,
ByteBuf msg,
List<Object> out)
Encode from one message to an other.
|
acceptOutboundMessage, write
bind, channelActive, channelInactive, channelRead, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, close, connect, deregister, disconnect, exceptionCaught, flush, handlerAdded, handlerRemoved, isSharable, read, userEventTriggered
public SctpOutboundByteStreamHandler(int streamIdentifier, int protocolIdentifier)
streamIdentifier
- stream number, this should be >=0 or <= max stream number of the association.protocolIdentifier
- supported application protocol id.protected void encode(ChannelHandlerContext ctx, ByteBuf msg, List<Object> out) throws Exception
MessageToMessageEncoder
encode
in class MessageToMessageEncoder<ByteBuf>
ctx
- the ChannelHandlerContext
which this MessageToMessageEncoder
belongs tomsg
- the message to encode to an other oneout
- the List
into which the encoded msg should be added
needs to do some kind of aggragationException
- is thrown if an error accourCopyright © 2008–2015 The Netty Project. All rights reserved.