public class PollingConsumer extends AbstractPollingEndpoint
MessageHandler implementation
to a PollableChannel.lifecycleCondition, lifecycleLocklogger| Constructor and Description |
|---|
PollingConsumer(PollableChannel inputChannel,
MessageHandler handler) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
doStart()
Subclasses must implement this method with the start behavior.
|
protected void |
doStop()
Subclasses must implement this method with the stop behavior.
|
protected String |
getResourceKey()
Return the key under which the resource will be made available as an
attribute on the
IntegrationResourceHolder. |
protected Object |
getResourceToBind()
Return a resource (MessageSource etc) to bind when using transaction
synchronization.
|
protected void |
handleMessage(Message<?> message)
Handle a message.
|
protected Message<?> |
receiveMessage()
Obtain the next message (if one is available).
|
void |
setReceiveTimeout(long receiveTimeout) |
applyReceiveOnlyAdviceChain, getBeanClassLoader, isReceiveOnlyAdvice, onInit, setAdviceChain, setBeanClassLoader, setErrorHandler, setMaxMessagesPerPoll, setTaskExecutor, setTransactionSynchronizationFactory, setTriggerdoStop, getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stopafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getComponentType, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, toStringpublic PollingConsumer(PollableChannel inputChannel, MessageHandler handler)
public void setReceiveTimeout(long receiveTimeout)
protected void doStart()
AbstractEndpointAbstractEndpoint.lifecycleLock.doStart in class AbstractPollingEndpointprotected void doStop()
AbstractEndpointAbstractEndpoint.lifecycleLock.doStop in class AbstractPollingEndpointprotected void handleMessage(Message<?> message)
AbstractPollingEndpointhandleMessage in class AbstractPollingEndpointmessage - The message.protected Message<?> receiveMessage()
AbstractPollingEndpointreceiveMessage in class AbstractPollingEndpointprotected Object getResourceToBind()
AbstractPollingEndpointgetResourceToBind in class AbstractPollingEndpointprotected String getResourceKey()
AbstractPollingEndpointIntegrationResourceHolder. The default
ExpressionEvaluatingTransactionSynchronizationProcessor
makes this attribute available as a variable in SpEL expressions.getResourceKey in class AbstractPollingEndpoint