Uses of Class
org.springframework.integration.dsl.PollerSpec
Package
Description
Root package of the Spring Integration Java DSL.
-
Uses of PollerSpec in org.springframework.integration.dsl
Modifier and TypeMethodDescriptionSpecify AOPAdvice
s for thepollingTask
.static PollerSpec
static PollerSpec
PollerSpec.errorChannel
(String errorChannelName) Specify a bean name for theMessageChannel
to use for sending error message in case of polling failures.PollerSpec.errorChannel
(MessageChannel errorChannel) Specify aMessageChannel
to use for sending error message in case of polling failures.PollerSpec.errorHandler
(ErrorHandler errorHandler) PollerFactory.fixedDelay
(long period) PollerFactory.fixedDelay
(long period, long initialDelay) PollerFactory.fixedDelay
(long period, TimeUnit timeUnit) PollerFactory.fixedDelay
(long period, TimeUnit timeUnit, long initialDelay) static PollerSpec
Pollers.fixedDelay
(long period) static PollerSpec
Pollers.fixedDelay
(long period, long initialDelay) static PollerSpec
Pollers.fixedDelay
(long period, TimeUnit timeUnit) Deprecated, for removal: This API element is subject to removal in a future version.static PollerSpec
Pollers.fixedDelay
(long period, TimeUnit timeUnit, long initialDelay) Deprecated, for removal: This API element is subject to removal in a future version.since 6.0 in favor ofPollers.fixedDelay(Duration, Duration)
static PollerSpec
Pollers.fixedDelay
(Duration period) static PollerSpec
Pollers.fixedDelay
(Duration period, Duration initialDelay) PollerFactory.fixedRate
(long period) PollerFactory.fixedRate
(long period, long initialDelay) static PollerSpec
Pollers.fixedRate
(long period) static PollerSpec
Pollers.fixedRate
(long period, long initialDelay) static PollerSpec
Deprecated, for removal: This API element is subject to removal in a future version.since 6.0 in favor ofPollers.fixedRate(Duration)
static PollerSpec
Deprecated, for removal: This API element is subject to removal in a future version.since 6.0 in favor ofPollers.fixedRate(Duration, Duration)
static PollerSpec
static PollerSpec
PollerSpec.maxMessagesPerPoll
(long maxMessagesPerPoll) PollerSpec.receiveTimeout
(long receiveTimeout) Specify a timeout in milliseconds to wait for a message in theMessageChannel
.PollerSpec.sendTimeout
(long sendTimeout) PollerSpec.taskExecutor
(Executor taskExecutor) Specify anExecutor
to perform thepollingTask
.PollerSpec.transactional()
Specify aTransactionInterceptor
Advice
with defaultPlatformTransactionManager
andDefaultTransactionAttribute
for thepollingTask
.PollerSpec.transactional
(TransactionInterceptor transactionInterceptor) PollerSpec.transactional
(TransactionManager transactionManager) Specify aTransactionInterceptor
Advice
with the providedPlatformTransactionManager
and defaultDefaultTransactionAttribute
for thepollingTask
.PollerSpec.transactionSynchronizationFactory
(TransactionSynchronizationFactory transactionSynchronizationFactory) Specify theTransactionSynchronizationFactory
to attach aTransactionSynchronization
to the transaction aroundpoll
operation.static PollerSpec
Modifier and TypeMethodDescriptionEndpointSpec.poller
(Function<PollerFactory, PollerSpec> pollers)
Pollers.fixedDelay(Duration)