|
|||||||||
| 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()
AbstractEndpointAbstractEndpoint.lifecycleLock.
doStart in class AbstractPollingEndpointprotected void doStop()
AbstractEndpointAbstractEndpoint.lifecycleLock.
doStop in class AbstractPollingEndpointprotected 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
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||