public abstract class AbstractPollableChannel extends AbstractMessageChannel implements org.springframework.messaging.PollableChannel
AbstractMessageChannel.ChannelInterceptorListlogger| Constructor and Description |
|---|
AbstractPollableChannel() |
| Modifier and Type | Method and Description |
|---|---|
protected abstract org.springframework.messaging.Message<?> |
doReceive(long timeout)
Subclasses must implement this method.
|
org.springframework.messaging.Message<?> |
receive()
Receive the first available message from this channel.
|
org.springframework.messaging.Message<?> |
receive(long timeout)
Receive the first available message from this channel.
|
addInterceptor, doSend, getComponentType, getFullChannelName, getInterceptors, send, send, setConversionService, setDatatypes, setInterceptors, setShouldTrackafterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, onInit, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetComponentNamepublic final org.springframework.messaging.Message<?> receive()
receive in interface org.springframework.messaging.PollableChannelnull if the
receiving thread is interrupted.public final org.springframework.messaging.Message<?> receive(long timeout)
receive()).receive in interface org.springframework.messaging.PollableChanneltimeout - the timeout in millisecondsnull if no message
is available within the allotted time or the receiving thread is
interrupted.protected abstract org.springframework.messaging.Message<?> doReceive(long timeout)