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, writebind, channelActive, channelInactive, channelRead, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, close, connect, deregister, disconnect, exceptionCaught, flush, handlerAdded, handlerRemoved, isSharable, read, userEventTriggeredpublic 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
MessageToMessageEncoderencode 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.