Close the channel.
Close the channel.
the signal indicating why the channel is closed
Check if the channel is closed.
Check if the channel is closed.
Some signal if the channel is closed
Send a segment accompanied by an optional termination signal.
Send a segment accompanied by an optional termination signal.
the segment
the optional termination signal
if the channel is poisoned. The segment will be poisoned.
Send the last segment.
Send the last segment.
the signal indicating why the channel is closed
if the channel is poisoned. In this case, the message will be poisoned.
Send the last message.
Send the last message.
the message
the signal indicating why the channel is closed
if the channel is poisoned. In this case, the message will be poisoned.
Send a segment
Send a segment
the segment
if the channel is poisoned. The message will be poisoned.
Send a message
Send a message
the message
if the channel is poisoned. The message will be poisoned.
A NativeProducer interfaces permits to produce messages in a blocking manner from a native thread. This interface is typically used to wrap a cooperative system-level output channel interface into an interface that can be manipulated easily from a native Java thread.
It is also common to wrap a Buffer channel of a sufficient large size inside this interface to produce messages asynchronously and in a non-blocking manner from a cooperative process. This works as long as the maximum number buffer size required in order to not block is guaranteed by the application protocol (i.e. request-ack).
the type of the messages carried by this channel.
ConsumerInterface to receive messages from an external thread.