public abstract class AbstractMessageSourceConduit<D extends MessageSourceConduit> extends AbstractSourceConduit<D> implements MessageSourceConduit
next
Modifier | Constructor and Description |
---|---|
protected |
AbstractMessageSourceConduit(D next)
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
protected AbstractMessageSourceConduit(D next)
next
- the delegate conduit to setpublic 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 © 2016 JBoss by Red Hat. All rights reserved.