public abstract class AbstractPollableChannel extends AbstractMessageChannel implements PollableChannel, PollableChannelManagement
AbstractMessageChannel.ChannelInterceptorListloggerINDEFINITE_TIMEOUT| Constructor and Description |
|---|
AbstractPollableChannel() |
| Modifier and Type | Method and Description |
|---|---|
protected abstract Message<?> |
doReceive(long timeout)
Subclasses must implement this method.
|
int |
getReceiveCount() |
long |
getReceiveCountLong() |
int |
getReceiveErrorCount() |
long |
getReceiveErrorCountLong() |
Message<?> |
receive()
Receive the first available message from this channel.
|
Message<?> |
receive(long timeout)
Receive the first available message from this channel.
|
addInterceptor, addInterceptor, configureMetrics, doSend, enableCounts, enableStats, getChannelInterceptors, getComponentType, getErrorRate, getFullChannelName, getInterceptors, getMaxSendDuration, getMeanErrorRate, getMeanErrorRatio, getMeanSendDuration, getMeanSendRate, getMetrics, getMinSendDuration, getSendCount, getSendCountLong, getSendDuration, getSendErrorCount, getSendErrorCountLong, getSendRate, getStandardDeviationSendDuration, getTimeSinceLastSend, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onInit, removeInterceptor, removeInterceptor, reset, send, send, setConversionService, setDatatypes, setInterceptors, setLoggingEnabled, setMessageConverter, setShouldTrackafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setMessageBuilderFactory, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitsend, sendgetErrorRate, getMaxSendDuration, getMeanErrorRate, getMeanErrorRatio, getMeanSendDuration, getMeanSendRate, getMinSendDuration, getSendCount, getSendCountLong, getSendDuration, getSendErrorCount, getSendErrorCountLong, getSendRate, getStandardDeviationSendDuration, getTimeSinceLastSendenableStats, isStatsEnabledenableCounts, isCountsEnabled, isLoggingEnabled, reset, setLoggingEnabledgetComponentNamepublic int getReceiveCount()
getReceiveCount in interface PollableChannelManagementpublic long getReceiveCountLong()
getReceiveCountLong in interface PollableChannelManagementpublic int getReceiveErrorCount()
getReceiveErrorCount in interface PollableChannelManagementpublic long getReceiveErrorCountLong()
getReceiveErrorCountLong in interface PollableChannelManagementpublic final Message<?> receive()
receive in interface PollableChannelnull if the
receiving thread is interrupted.public final Message<?> receive(long timeout)
receive()).receive in interface PollableChanneltimeout - the timeout in millisecondsnull if no message
is available within the allotted time or the receiving thread is
interrupted.protected abstract Message<?> doReceive(long timeout)
timeout - The timeout.