|
Spring Integration | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.endpoint.AbstractPollingEndpoint
org.springframework.integration.endpoint.PollingConsumer
public class PollingConsumer
Message Endpoint that connects any MessageHandler
implementation
to a PollableChannel
.
Field Summary |
---|
Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport |
---|
logger |
Constructor Summary | |
---|---|
PollingConsumer(PollableChannel inputChannel,
MessageHandler handler)
|
Method Summary | |
---|---|
protected boolean |
doPoll()
|
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(Message<?> message)
Handle a message. |
protected Message<?> |
receiveMessage()
Obtain the next message (if one is available). |
void |
setReceiveTimeout(long receiveTimeout)
|
void |
setTransactionSynchronizationFactory(TransactionSynchronizationFactory transactionSynchronizationFactory)
|
Methods inherited from class org.springframework.integration.endpoint.AbstractPollingEndpoint |
---|
onInit, setAdviceChain, setBeanClassLoader, setErrorHandler, setMaxMessagesPerPoll, setPollerMetadata, setTaskExecutor, setTrigger |
Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint |
---|
getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stop |
Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport |
---|
afterPropertiesSet, getBeanFactory, getComponentName, getComponentType, getConversionService, getTaskScheduler, setBeanFactory, setBeanName, setComponentName, setConversionService, toString |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public PollingConsumer(PollableChannel inputChannel, MessageHandler handler)
Method Detail |
---|
public void setReceiveTimeout(long receiveTimeout)
protected void doStart()
AbstractEndpoint
AbstractEndpoint.lifecycleLock
.
doStart
in class AbstractPollingEndpoint
protected void doStop()
AbstractEndpoint
AbstractEndpoint.lifecycleLock
.
doStop
in class AbstractPollingEndpoint
protected void handleMessage(Message<?> message)
message
- The message.protected Message<?> receiveMessage()
protected java.lang.Object getResourceToBind()
protected java.lang.String getResourceKey()
IntegrationResourceHolder
. The default
ExpressionEvaluatingTransactionSynchronizationProcessor
makes this attribute available as a variable in SpEL expressions.
public void setTransactionSynchronizationFactory(TransactionSynchronizationFactory transactionSynchronizationFactory)
protected final boolean doPoll()
doPoll
in class AbstractPollingEndpoint
|
Spring Integration | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |