public interface MessageSourceConduit extends SourceConduit
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
int receive(java.nio.ByteBuffer dst) throws java.io.IOException
buffer
- the buffer that will hold the messagejava.io.IOException
- if an I/O error occurslong receive(java.nio.ByteBuffer[] dsts, int offs, int len) throws java.io.IOException
buffers
- the buffers that will hold the messageoffs
- 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.