| Access | Constructor and Description |
|---|---|
| public | SynchronizedMessageSinkConduit(final MessageSinkConduit
the next conduit in the chain next)Construct a new instance. |
| public | SynchronizedMessageSinkConduit(final MessageSinkConduit
the next conduit in the chain next, final Object the lock object to use lock)Construct a new instance. |
| Modifier and Type | Method and Description |
|---|---|
| public boolean | send(final ByteBuffer
the message to send src)Implements org. Send a complete message. |
| public boolean | send(final ByteBuffer[]
the buffers holding the message to send srcs, final int the offset into the buffer array of the first buffer offs, final int the number of buffers that contain data to send len)Implements org. Send a complete message. |
| public boolean | sendFinal(final ByteBuffer
the message to send src)Implements org. Send a complete message. |
| public boolean | sendFinal(final ByteBuffer[]
the buffers holding the message to send srcs, final int the offset into the buffer array of the first buffer offs, final int the number of buffers that contain data to send len)Implements org. Send a complete message. |
| SynchronizedMessageSinkConduit | back to summary |
|---|---|
| public SynchronizedMessageSinkConduit(final MessageSinkConduit next) Construct a new instance. A new lock object is created.
| |
| SynchronizedMessageSinkConduit | back to summary |
|---|---|
| public SynchronizedMessageSinkConduit(final MessageSinkConduit next, final Object lock) Construct a new instance.
| |
| send | back to summary |
|---|---|
| public boolean send(final ByteBuffer src) throws IOException Implements org. Doc from org. Send a complete message.
| |
| send | back to summary |
|---|---|
| public boolean send(final ByteBuffer[] srcs, final int offs, final int len) throws IOException Implements org. Doc from org. Send a complete message.
| |
| sendFinal | back to summary |
|---|---|
| public boolean sendFinal(final ByteBuffer src) throws IOException Implements org. Doc from org. Send a complete message. If the message is successfully sent then the sink will have its writes terminated.
| |
| sendFinal | back to summary |
|---|---|
| public boolean sendFinal(final ByteBuffer[] srcs, final int offs, final int len) throws IOException Implements org. Doc from org. Send a complete message. If the message is successfully sent then the sink will have its writes terminated.
| |