public class SourcePollingChannelAdapter extends AbstractPollingEndpoint implements TrackableComponent
MessageSource to a MessageChannel.logger| Constructor and Description |
|---|
SourcePollingChannelAdapter() |
| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
getComponentType()
Subclasses may implement this method to provide component type information.
|
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 void |
onInit()
Subclasses may implement this for initialization logic.
|
protected org.springframework.messaging.Message<?> |
receiveMessage()
Obtain the next message (if one is available).
|
void |
setOutputChannel(org.springframework.messaging.MessageChannel outputChannel)
Specify the
MessageChannel where Messages should be sent. |
void |
setSendTimeout(long sendTimeout)
Specify the maximum time to wait for a Message to be sent to the
output channel.
|
void |
setShouldTrack(boolean shouldTrack)
Specify whether this component should be tracked in the Message History.
|
void |
setSource(MessageSource<?> source)
Specify the source to be polled for Messages.
|
doStart, doStop, setAdviceChain, setBeanClassLoader, setErrorHandler, setMaxMessagesPerPoll, setTaskExecutor, setTransactionSynchronizationFactory, setTriggergetPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stopafterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetComponentNamepublic void setSource(MessageSource<?> source)
public void setOutputChannel(org.springframework.messaging.MessageChannel outputChannel)
MessageChannel where Messages should be sent.public void setSendTimeout(long sendTimeout)
public void setShouldTrack(boolean shouldTrack)
setShouldTrack in interface TrackableComponentpublic java.lang.String getComponentType()
IntegrationObjectSupportgetComponentType in interface NamedComponentgetComponentType in class IntegrationObjectSupportprotected void onInit()
IntegrationObjectSupportonInit 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