public class SctpOutboundByteStreamHandler extends MessageToMessageEncoder<ByteBuf>
ByteBuf
to SctpMessage
and send it through a specific stream
with given protocol identifier.
Unordered delivery of all messages may be requested by passing unordered = true to the constructor.ChannelHandler.Sharable
构造器和说明 |
---|
SctpOutboundByteStreamHandler(int streamIdentifier,
int protocolIdentifier) |
SctpOutboundByteStreamHandler(int streamIdentifier,
int protocolIdentifier,
boolean unordered) |
限定符和类型 | 方法和说明 |
---|---|
protected void |
encode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out)
Encode from one message to an other.
|
acceptOutboundMessage, write
bind, close, connect, deregister, disconnect, flush, read
ensureNotSharable, exceptionCaught, handlerAdded, handlerRemoved, isSharable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
exceptionCaught, handlerAdded, handlerRemoved
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.public SctpOutboundByteStreamHandler(int streamIdentifier, int protocolIdentifier, boolean unordered)
streamIdentifier
- stream number, this should be >=0 or <= max stream number of the association.protocolIdentifier
- supported application protocol id.unordered
- if true, SCTP Data Chunks will be sent with the U (unordered) flag set.protected void encode(ChannelHandlerContext ctx, ByteBuf msg, java.util.List<java.lang.Object> out) throws java.lang.Exception
MessageToMessageEncoder
encode
在类中 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 aggregationjava.lang.Exception
- is thrown if an error occurs