Package io.netty.handler.codec.sctp
Class SctpOutboundByteStreamHandler
java.lang.Object
io.netty.channel.ChannelHandlerAdapter
io.netty.channel.ChannelOutboundHandlerAdapter
io.netty.handler.codec.MessageToMessageEncoder<ByteBuf>
io.netty.handler.codec.sctp.SctpOutboundByteStreamHandler
- All Implemented Interfaces:
ChannelHandler
,ChannelOutboundHandler
A ChannelHandler which transform
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.-
Nested Class Summary
Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler
ChannelHandler.Sharable
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final int
private final int
private final boolean
-
Constructor Summary
ConstructorsConstructorDescriptionSctpOutboundByteStreamHandler
(int streamIdentifier, int protocolIdentifier) SctpOutboundByteStreamHandler
(int streamIdentifier, int protocolIdentifier, boolean unordered) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
encode
(ChannelHandlerContext ctx, ByteBuf msg, List<Object> out) Encode from one message to an other.Methods inherited from class io.netty.handler.codec.MessageToMessageEncoder
acceptOutboundMessage, write
Methods inherited from class io.netty.channel.ChannelOutboundHandlerAdapter
bind, close, connect, deregister, disconnect, flush, read
Methods inherited from class io.netty.channel.ChannelHandlerAdapter
ensureNotSharable, exceptionCaught, handlerAdded, handlerRemoved, isSharable
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface io.netty.channel.ChannelHandler
exceptionCaught, handlerAdded, handlerRemoved
-
Field Details
-
streamIdentifier
private final int streamIdentifier -
protocolIdentifier
private final int protocolIdentifier -
unordered
private final boolean unordered
-
-
Constructor Details
-
SctpOutboundByteStreamHandler
public SctpOutboundByteStreamHandler(int streamIdentifier, int protocolIdentifier) - Parameters:
streamIdentifier
- stream number, this should be >=0 or invalid input: '<'= max stream number of the association.protocolIdentifier
- supported application protocol id.
-
SctpOutboundByteStreamHandler
public SctpOutboundByteStreamHandler(int streamIdentifier, int protocolIdentifier, boolean unordered) - Parameters:
streamIdentifier
- stream number, this should be >=0 or invalid input: '<'= 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.
-
-
Method Details
-
encode
Description copied from class:MessageToMessageEncoder
Encode from one message to an other. This method will be called for each written message that can be handled by this encoder.- Specified by:
encode
in classMessageToMessageEncoder<ByteBuf>
- Parameters:
ctx
- theChannelHandlerContext
which thisMessageToMessageEncoder
belongs tomsg
- the message to encode to an other oneout
- theList
into which the encoded msg should be added needs to do some kind of aggregation- Throws:
Exception
- is thrown if an error occurs
-