public final class SynchronizedMessageSinkConduit extends AbstractSynchronizedSinkConduit<MessageSinkConduit> implements MessageSinkConduit
lock
next
Constructor and Description |
---|
SynchronizedMessageSinkConduit(MessageSinkConduit next)
Construct a new instance.
|
SynchronizedMessageSinkConduit(MessageSinkConduit next,
Object lock)
Construct a new instance.
|
Modifier and Type | Method and Description |
---|---|
boolean |
send(ByteBuffer src)
Send a complete message.
|
boolean |
send(ByteBuffer[] srcs,
int offs,
int len)
Send a complete message.
|
boolean |
sendFinal(ByteBuffer src)
Send a complete message.
|
boolean |
sendFinal(ByteBuffer[] srcs,
int offs,
int len)
Send a complete message.
|
awaitWritable, awaitWritable, flush, getWriteThread, isWriteResumed, isWriteShutdown, resumeWrites, setWriteReadyHandler, suspendWrites, terminateWrites, truncateWrites, wakeupWrites
getWorker
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
awaitWritable, awaitWritable, flush, getWriteThread, isWriteResumed, isWriteShutdown, resumeWrites, setWriteReadyHandler, suspendWrites, terminateWrites, truncateWrites, wakeupWrites
public SynchronizedMessageSinkConduit(MessageSinkConduit next)
next
- the next conduit in the chainpublic SynchronizedMessageSinkConduit(MessageSinkConduit next, Object lock)
next
- the next conduit in the chainlock
- the lock object to usepublic boolean send(ByteBuffer src) throws IOException
MessageSinkConduit
send
in interface MessageSinkConduit
src
- the message to sendtrue
if the message was sent, or false
if it would blockIOException
- if an I/O error occurspublic boolean send(ByteBuffer[] srcs, int offs, int len) throws IOException
MessageSinkConduit
send
in interface MessageSinkConduit
srcs
- the buffers holding the message to sendoffs
- the offset into the buffer array of the first bufferlen
- the number of buffers that contain data to sendtrue
if the message was sent, or false
if it would blockIOException
- if an I/O error occurspublic boolean sendFinal(ByteBuffer src) throws IOException
MessageSinkConduit
sendFinal
in interface MessageSinkConduit
src
- the message to sendtrue
if the message was sent, or false
if it would blockIOException
- if an I/O error occurspublic boolean sendFinal(ByteBuffer[] srcs, int offs, int len) throws IOException
MessageSinkConduit
sendFinal
in interface MessageSinkConduit
srcs
- the buffers holding the message to sendoffs
- the offset into the buffer array of the first bufferlen
- the number of buffers that contain data to sendtrue
if the message was sent, or false
if it would blockIOException
- if an I/O error occursCopyright © 2017 JBoss by Red Hat. All rights reserved.