org.springframework.integration.core
Interface PollableChannel

All Superinterfaces:

MessageChannel

All Known Implementing Classes:

AbstractPollableChannel, NullChannel, PollableAmqpChannel, PollableJmsChannel, PriorityChannel, QueueChannel, RendezvousChannel

public interface PollableChannel
extends MessageChannel

Interface for Message Channels from which Messages may be actively received through polling.

Author:

Mark Fisher

Method Summary

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.

Methods inherited from interface org.springframework.integration.MessageChannel

send, send

Method Detail

receive

Message<?> receive()

Receive a message from this channel, blocking indefinitely if necessary.

Returns:

the next available Message or null if interrupted

receive

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

Returns:

the next available Message or null if the specified timeout period elapses or the message reception is interrupted