public final class PollerSpec extends IntegrationComponentSpec<PollerSpec,org.springframework.integration.scheduling.PollerMetadata>
IntegrationComponentSpec
for PollerMetadata
s.id, logger, PARSER, target
Modifier and Type | Method and Description |
---|---|
PollerSpec |
advice(org.aopalliance.aop.Advice... advice)
Specify AOP
Advice s 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, id
public 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)
Advice
s for the pollingTask
.advice
- the Advice
s 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>