public interface PollableChannel extends MessageChannel
MessageChannel
from which messages may be actively received through polling.INDEFINITE_TIMEOUT
Modifier and Type | Method and Description |
---|---|
Message<?> |
receive()
Receive a message from this channel, blocking indefinitely if necessary.
|
Message<?> |
receive(long timeout)
Receive a message from this channel, blocking until either a message is available
or the specified timeout period elapses.
|
send, send
Message<?> receive()
Message
or null
if interruptedMessage<?> receive(long timeout)
timeout
- the timeout in milliseconds or MessageChannel.INDEFINITE_TIMEOUT
.Message
or null
if the specified timeout
period elapses or the message reception is interrupted