public final class SynchronizedMessageSourceConduit extends AbstractSynchronizedSourceConduit<MessageSourceConduit> implements MessageSourceConduit
lock
next
Constructor and Description |
---|
SynchronizedMessageSourceConduit(MessageSourceConduit next)
Construct a new instance.
|
SynchronizedMessageSourceConduit(MessageSourceConduit next,
java.lang.Object lock)
Construct a new instance.
|
Modifier and Type | Method and Description |
---|---|
int |
receive(java.nio.ByteBuffer dst)
Receive a message.
|
long |
receive(java.nio.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, java.lang.Object lock)
next
- the next conduit in the chainlock
- the lock object to usepublic int receive(java.nio.ByteBuffer dst) throws java.io.IOException
MessageSourceConduit
receive
in interface MessageSourceConduit
java.io.IOException
- if an I/O error occurspublic long receive(java.nio.ByteBuffer[] dsts, int offs, int len) throws java.io.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 filljava.io.IOException
- if an I/O error occursCopyright © 2016 JBoss, a division of Red Hat, Inc.