public final class PollerSpec extends IntegrationComponentSpec<PollerSpec,PollerMetadata> implements ComponentsRegistration
IntegrationComponentSpec for PollerMetadatas.logger, PARSER, target| Modifier and Type | Method and Description |
|---|---|
PollerSpec |
advice(Advice... advice)
Specify AOP
Advices for the pollingTask. |
PollerSpec |
errorChannel(MessageChannel errorChannel)
Specify a
MessageChannel to use for sending error message in case
of polling failures. |
PollerSpec |
errorChannel(String errorChannelName)
Specify a bean name for the
MessageChannel to use for sending error message in case
of polling failures. |
PollerSpec |
errorHandler(ErrorHandler errorHandler)
|
Collection<Object> |
getComponentsToRegister() |
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(Executor taskExecutor)
Specify an
Executor to perform the pollingTask. |
PollerSpec |
transactional()
Specify a
TransactionInterceptor Advice with default PlatformTransactionManager
and DefaultTransactionAttribute for the pollingTask. |
PollerSpec |
transactional(PlatformTransactionManager transactionManager)
Specify a
TransactionInterceptor Advice with the
provided PlatformTransactionManager and default DefaultTransactionAttribute
for the pollingTask. |
PollerSpec |
transactional(TransactionInterceptor transactionInterceptor)
|
PollerSpec |
transactionSynchronizationFactory(TransactionSynchronizationFactory transactionSynchronizationFactory)
Specify the
TransactionSynchronizationFactory to attach a
TransactionSynchronization
to the transaction around poll operation. |
_this, doGet, get, getId, getObject, getObjectType, id, isSingletonpublic PollerSpec transactionSynchronizationFactory(TransactionSynchronizationFactory transactionSynchronizationFactory)
TransactionSynchronizationFactory to attach a
TransactionSynchronization
to the transaction around poll operation.transactionSynchronizationFactory - the TransactionSynchronizationFactory to use.public PollerSpec errorHandler(ErrorHandler errorHandler)
errorHandler - the ErrorHandler to use.taskExecutor(java.util.concurrent.Executor)public PollerSpec errorChannel(MessageChannel errorChannel)
MessageChannel to use for sending error message in case
of polling failures.errorChannel - the MessageChannel to use.MessagePublishingErrorHandlerpublic PollerSpec errorChannel(String errorChannelName)
MessageChannel to use for sending error message in case
of polling failures.errorChannelName - the bean name for MessageChannel to use.MessagePublishingErrorHandlerpublic 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(Advice... advice)
Advices for the pollingTask.advice - the Advices to use.public PollerSpec transactional(PlatformTransactionManager transactionManager)
TransactionInterceptor Advice with the
provided PlatformTransactionManager and default DefaultTransactionAttribute
for the pollingTask.transactionManager - the PlatformTransactionManager to use.public PollerSpec transactional()
TransactionInterceptor Advice with default PlatformTransactionManager
and DefaultTransactionAttribute for the pollingTask.public PollerSpec transactional(TransactionInterceptor transactionInterceptor)
transactionInterceptor - the TransactionInterceptor to use.TransactionInterceptorBuilderpublic PollerSpec taskExecutor(Executor taskExecutor)
Executor to perform the pollingTask.taskExecutor - the Executor to use.public PollerSpec sendTimeout(long sendTimeout)
public Collection<Object> getComponentsToRegister()
getComponentsToRegister in interface ComponentsRegistration