public class PollingConsumer extends AbstractPollingEndpoint
MessageHandler implementation
to a PollableChannel.logger| Constructor and Description |
|---|
PollingConsumer(org.springframework.messaging.PollableChannel inputChannel,
org.springframework.messaging.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 java.lang.String |
getResourceKey()
Return the key under which the resource will be made available as an
attribute on the
IntegrationResourceHolder. |
protected java.lang.Object |
getResourceToBind()
Return a resource (MessageSource etc) to bind when using transaction
synchronization.
|
protected void |
handleMessage(org.springframework.messaging.Message<?> message)
Handle a message.
|
protected org.springframework.messaging.Message<?> |
receiveMessage()
Obtain the next message (if one is available).
|
void |
setReceiveTimeout(long receiveTimeout) |
onInit, setAdviceChain, setBeanClassLoader, setErrorHandler, setMaxMessagesPerPoll, setTaskExecutor, setTransactionSynchronizationFactory, setTriggergetPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stopafterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getComponentType, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, toStringpublic PollingConsumer(org.springframework.messaging.PollableChannel inputChannel,
org.springframework.messaging.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(org.springframework.messaging.Message<?> message)
AbstractPollingEndpointhandleMessage in class AbstractPollingEndpointmessage - The message.protected org.springframework.messaging.Message<?> receiveMessage()
AbstractPollingEndpointreceiveMessage in class AbstractPollingEndpointprotected java.lang.Object getResourceToBind()
AbstractPollingEndpointgetResourceToBind in class AbstractPollingEndpointprotected java.lang.String getResourceKey()
AbstractPollingEndpointIntegrationResourceHolder. The default
ExpressionEvaluatingTransactionSynchronizationProcessor
makes this attribute available as a variable in SpEL expressions.getResourceKey in class AbstractPollingEndpoint