Uses of Class
org.springframework.integration.dsl.DelayerEndpointSpec
Package
Description
Root package of the Spring Integration Java DSL.
-
Uses of DelayerEndpointSpec in org.springframework.integration.dsl
Modifier and TypeMethodDescriptionDelayerEndpointSpec.defaultDelay
(long defaultDelay) DelayerEndpointSpec.delayedAdvice
(Advice... advice) Configure a list ofAdvice
objects that will be applied, in nested order, when delayed messages are sent.DelayerEndpointSpec.delayedMessageErrorChannel
(String channel) Set a message channel name to which anErrorMessage
will be sent if sending the released message fails.DelayerEndpointSpec.delayedMessageErrorChannel
(MessageChannel channel) Set a message channel to which anErrorMessage
will be sent if sending the released message fails.DelayerEndpointSpec.delayExpression
(String delayExpression) DelayerEndpointSpec.delayExpression
(Expression delayExpression) DelayerEndpointSpec.delayFunction
(Function<Message<P>, Object> delayFunction) Specify the function to determine delay value againstMessage
.DelayerEndpointSpec.ignoreExpressionFailures
(boolean ignoreExpressionFailures) DelayerEndpointSpec.maxAttempts
(int maxAttempts) Set the maximum number of release attempts for when message release fails.DelayerEndpointSpec.messageStore
(MessageGroupStore messageStore) DelayerEndpointSpec.retryDelay
(long retryDelay) Set an additional delay to apply when retrying after a release failure.DelayerEndpointSpec.transactionalRelease()
Specify aTransactionInterceptor
Advice
with defaultTransactionManager
andDefaultTransactionAttribute
for theMessageHandler
.DelayerEndpointSpec.transactionalRelease
(TransactionInterceptor transactionInterceptor) DelayerEndpointSpec.transactionalRelease
(TransactionManager transactionManager) Specify aTransactionInterceptor
Advice
with the providedTransactionManager
and defaultDefaultTransactionAttribute
for theMessageHandler
.Modifier and TypeMethodDescriptionBaseIntegrationFlowDefinition.delay
(String groupId, Consumer<DelayerEndpointSpec> endpointConfigurer) Populate aDelayHandler
to the current integration flow position.