public final class PollerSpec extends IntegrationComponentSpec<PollerSpec,org.springframework.integration.scheduling.PollerMetadata>
IntegrationComponentSpec for PollerMetadatas.id, logger, PARSER, target| Modifier and Type | Method and Description |
|---|---|
PollerSpec |
advice(org.aopalliance.aop.Advice... advice)
Specify AOP
Advices for the pollingTask. |
protected org.springframework.integration.scheduling.PollerMetadata |
doGet() |
PollerSpec |
errorHandler(org.springframework.util.ErrorHandler errorHandler)
Specify the
ErrorHandler to wrap a taskExecutor
to the ErrorHandlingTaskExecutor. |
PollerSpec |
maxMessagesPerPoll(long maxMessagesPerPoll) |
PollerSpec |
receiveTimeout(long receiveTimeout)
Specify a timeout in milliseconds to wait for a message in the
MessageChannel. |
PollerSpec |
sendTimeout(long sendTimeout) |
PollerSpec |
taskExecutor(java.util.concurrent.Executor taskExecutor)
Specify an
Executor to perform the pollingTask. |
PollerSpec |
transactional(org.springframework.transaction.PlatformTransactionManager transactionManager)
Specify a
TransactionInterceptor Advice with the
provided PlatformTransactionManager for the pollingTask. |
PollerSpec |
transactionSynchronizationFactory(org.springframework.integration.transaction.TransactionSynchronizationFactory transactionSynchronizationFactory)
Specify the
TransactionSynchronizationFactory to attach a
TransactionSynchronization
to the transaction around poll operation. |
_this, get, getId, idpublic PollerSpec transactionSynchronizationFactory(org.springframework.integration.transaction.TransactionSynchronizationFactory transactionSynchronizationFactory)
TransactionSynchronizationFactory to attach a
TransactionSynchronization
to the transaction around poll operation.transactionSynchronizationFactory - the TransactionSynchronizationFactory to use.public PollerSpec errorHandler(org.springframework.util.ErrorHandler errorHandler)
ErrorHandler to wrap a taskExecutor
to the ErrorHandlingTaskExecutor.errorHandler - the ErrorHandler to use.taskExecutor(java.util.concurrent.Executor)public PollerSpec maxMessagesPerPoll(long maxMessagesPerPoll)
maxMessagesPerPoll - the maxMessagesPerPoll to set.PollerMetadata.setMaxMessagesPerPoll(long)public PollerSpec receiveTimeout(long receiveTimeout)
MessageChannel.
Defaults to 1000.receiveTimeout - the timeout to use.PollableChannel.receive(long)public PollerSpec advice(org.aopalliance.aop.Advice... advice)
Advices for the pollingTask.advice - the Advices to use.public PollerSpec transactional(org.springframework.transaction.PlatformTransactionManager transactionManager)
TransactionInterceptor Advice with the
provided PlatformTransactionManager for the pollingTask.transactionManager - the PlatformTransactionManager to use.public PollerSpec taskExecutor(java.util.concurrent.Executor taskExecutor)
Executor to perform the pollingTask.taskExecutor - the Executor to use.public PollerSpec sendTimeout(long sendTimeout)
protected org.springframework.integration.scheduling.PollerMetadata doGet()
doGet in class IntegrationComponentSpec<PollerSpec,org.springframework.integration.scheduling.PollerMetadata>