public final class SynchronizedMessageSourceConduit extends AbstractSynchronizedSourceConduit<MessageSourceConduit> implements MessageSourceConduit
lock
next
Constructor and Description |
---|
SynchronizedMessageSourceConduit(MessageSourceConduit next)
Construct a new instance.
|
SynchronizedMessageSourceConduit(MessageSourceConduit next,
Object lock)
Construct a new instance.
|
Modifier and Type | Method and Description |
---|---|
int |
receive(ByteBuffer dst)
Receive a message.
|
long |
receive(ByteBuffer[] dsts,
int offs,
int len)
Receive a message.
|
awaitReadable, awaitReadable, getReadThread, isReadResumed, isReadShutdown, resumeReads, setReadReadyHandler, suspendReads, terminateReads, wakeupReads
getWorker
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
awaitReadable, awaitReadable, getReadThread, isReadResumed, isReadShutdown, resumeReads, setReadReadyHandler, suspendReads, terminateReads, wakeupReads
public SynchronizedMessageSourceConduit(MessageSourceConduit next)
next
- the next conduit in the chainpublic SynchronizedMessageSourceConduit(MessageSourceConduit next, Object lock)
next
- the next conduit in the chainlock
- the lock object to usepublic int receive(ByteBuffer dst) throws IOException
MessageSourceConduit
receive
in interface MessageSourceConduit
IOException
- if an I/O error occurspublic long receive(ByteBuffer[] dsts, int offs, int len) throws IOException
MessageSourceConduit
receive
in interface MessageSourceConduit
offs
- the offset into the array of buffers of the first buffer to read intolen
- the number of buffers to fillIOException
- if an I/O error occursCopyright © 2017 JBoss by Red Hat. All rights reserved.