public abstract class AbstractPollingEndpoint extends AbstractEndpoint implements org.springframework.beans.factory.BeanClassLoaderAware
logger| Constructor and Description |
|---|
AbstractPollingEndpoint() |
| 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 abstract void |
handleMessage(org.springframework.messaging.Message<?> message)
Handle a message.
|
protected void |
onInit()
Subclasses may implement this for initialization logic.
|
protected abstract org.springframework.messaging.Message<?> |
receiveMessage()
Obtain the next message (if one is available).
|
void |
setAdviceChain(java.util.List<org.aopalliance.aop.Advice> adviceChain) |
void |
setBeanClassLoader(java.lang.ClassLoader classLoader) |
void |
setErrorHandler(org.springframework.util.ErrorHandler errorHandler) |
void |
setMaxMessagesPerPoll(long maxMessagesPerPoll) |
void |
setTaskExecutor(java.util.concurrent.Executor taskExecutor) |
void |
setTransactionSynchronizationFactory(TransactionSynchronizationFactory transactionSynchronizationFactory) |
void |
setTrigger(org.springframework.scheduling.Trigger trigger) |
getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stopafterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getComponentType, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, toStringpublic void setTaskExecutor(java.util.concurrent.Executor taskExecutor)
public void setTrigger(org.springframework.scheduling.Trigger trigger)
public void setAdviceChain(java.util.List<org.aopalliance.aop.Advice> adviceChain)
public void setMaxMessagesPerPoll(long maxMessagesPerPoll)
public void setErrorHandler(org.springframework.util.ErrorHandler errorHandler)
public void setBeanClassLoader(java.lang.ClassLoader classLoader)
setBeanClassLoader in interface org.springframework.beans.factory.BeanClassLoaderAwarepublic void setTransactionSynchronizationFactory(TransactionSynchronizationFactory transactionSynchronizationFactory)
protected void onInit()
IntegrationObjectSupportonInit in class IntegrationObjectSupportprotected void doStart()
AbstractEndpointAbstractEndpoint.lifecycleLock.doStart in class AbstractEndpointprotected void doStop()
AbstractEndpointAbstractEndpoint.lifecycleLock.doStop in class AbstractEndpointprotected abstract org.springframework.messaging.Message<?> receiveMessage()
protected abstract void handleMessage(org.springframework.messaging.Message<?> message)
message - The message.protected java.lang.Object getResourceToBind()
protected java.lang.String getResourceKey()
IntegrationResourceHolder. The default
ExpressionEvaluatingTransactionSynchronizationProcessor
makes this attribute available as a variable in SpEL expressions.