public interface ReadableMultipointMessageChannel extends SuspendableReadChannel
EMPTY
Modifier and Type | Method and Description |
---|---|
ChannelListener.Setter<? extends ReadableMultipointMessageChannel> |
getCloseSetter()
Get the setter which can be used to change the close listener for this channel.
|
ChannelListener.Setter<? extends ReadableMultipointMessageChannel> |
getReadSetter()
Get the setter which can be used to change the read listener for this channel.
|
int |
receiveFrom(SocketAddressBuffer addressBuffer,
ByteBuffer buffer)
Receive a message via this channel.
|
long |
receiveFrom(SocketAddressBuffer addressBuffer,
ByteBuffer[] buffers)
Receive a message.
|
long |
receiveFrom(SocketAddressBuffer addressBuffer,
ByteBuffer[] buffers,
int offs,
int len)
Receive a message.
|
awaitReadable, awaitReadable, getReadThread, isReadResumed, resumeReads, shutdownReads, suspendReads, wakeupReads
close, getIoThread, getWorker
getOption, setOption, supportsOption
int receiveFrom(SocketAddressBuffer addressBuffer, ByteBuffer buffer) throws IOException
addressBuffer
- the address buffer into which the source and destination addresses should be written (null
to discard that information)buffer
- the buffer into which data should be readIOException
- if an I/O error occurslong receiveFrom(SocketAddressBuffer addressBuffer, ByteBuffer[] buffers) throws IOException
addressBuffer
- the address buffer into which the source and destination addresses should be written (null
to discard that information)buffers
- the buffers that will hold the messageIOException
- if an I/O error occurslong receiveFrom(SocketAddressBuffer addressBuffer, ByteBuffer[] buffers, int offs, int len) throws IOException
addressBuffer
- the address buffer into which the source and destination addresses should be written (null
to discard that information)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 fillIOException
- if an I/O error occursChannelListener.Setter<? extends ReadableMultipointMessageChannel> getReadSetter()
getReadSetter
in interface SuspendableReadChannel
ChannelListener.Setter<? extends ReadableMultipointMessageChannel> getCloseSetter()
getCloseSetter
in interface CloseableChannel
getCloseSetter
in interface SuspendableReadChannel
Copyright © 2021 JBoss by Red Hat. All rights reserved.