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.messageGroupId
(String messageGroupId) Set a group id to manage delayed messages by this handler.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
(Consumer<DelayerEndpointSpec> endpointConfigurer) Populate aDelayHandler
to the current integration flow position.