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, sendMessage<?> 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