Interface PollableChannel

All Superinterfaces:
MessageChannel
public interface PollableChannel extends MessageChannel
A MessageChannel from which messages may be actively received through polling.
Since:
4.0
Author:
Mark Fisher

  • Field Summary

    Fields inherited from interface MessageChannel

    INDEFINITE_TIMEOUT

  • Method Summary

    Modifier and Type
    Method
    Description
    @Nullable Message<?>
    receive()
    Receive a message from this channel, blocking indefinitely if necessary.
    @Nullable Message<?>
    receive(long timeout)
    Receive a message from this channel, blocking until either a message is available or the specified timeout period elapses.

    Methods inherited from interface MessageChannel

    send, send

  • Method Details

    • receive

      @Nullable Message<?> receive()
      Receive a message from this channel, blocking indefinitely if necessary.
      Returns:
      the next available Message or null if interrupted

    • receive

      @Nullable Message<?> receive(long timeout)
      Receive a message from this channel, blocking until either a message is available or the specified timeout period elapses.
      Parameters:
      timeout - the timeout in milliseconds or MessageChannel.INDEFINITE_TIMEOUT
      Returns:
      the next available Message or null if the specified timeout period elapses or the message receipt is interrupted