org.springframework.integration.dsl

Class DelayerEndpointSpec

java.lang.Object

org.springframework.integration.dsl.IntegrationComponentSpec<S,reactor.util.function.Tuple2<F,H>>

org.springframework.integration.dsl.EndpointSpec<S,ConsumerEndpointFactoryBean,H>

org.springframework.integration.dsl.ConsumerEndpointSpec<DelayerEndpointSpec,DelayHandler>

org.springframework.integration.dsl.DelayerEndpointSpec

All Implemented Interfaces:

org.springframework.beans.factory.FactoryBean<reactor.util.function.Tuple2<ConsumerEndpointFactoryBean,DelayHandler>>, ComponentsRegistration

public final class DelayerEndpointSpec
extends ConsumerEndpointSpec<DelayerEndpointSpec,DelayHandler>

A ConsumerEndpointSpec for a DelayHandler.

Since:

5.0

Author:

Artem Bilan

Field Summary

Fields inherited from class org.springframework.integration.dsl.ConsumerEndpointSpec

adviceChain

Fields inherited from class org.springframework.integration.dsl.EndpointSpec

componentsToRegister, endpointFactoryBean, handler

Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

logger, PARSER, target

Method Summary

Modifier and Type	Method and Description
DelayerEndpointSpec	defaultDelay(long defaultDelay)
DelayerEndpointSpec	delayedAdvice(org.aopalliance.aop.Advice... advice) Configure a list of Advice objects that will be applied, in nested order, when delayed messages are sent.
DelayerEndpointSpec	delayExpression(org.springframework.expression.Expression delayExpression)
DelayerEndpointSpec	delayExpression(java.lang.String delayExpression)
<P> DelayerEndpointSpec	delayFunction(java.util.function.Function<org.springframework.messaging.Message<P>,java.lang.Object> delayFunction) Specify the function to determine delay value against Message.
DelayerEndpointSpec	ignoreExpressionFailures(boolean ignoreExpressionFailures)
DelayerEndpointSpec	messageStore(MessageGroupStore messageStore)

Methods inherited from class org.springframework.integration.dsl.ConsumerEndpointSpec

advice, async, autoStartup, doGet, notPropagatedHeaders, order, phase, poller, requiresReply, role, sendTimeout, taskScheduler, transactional, transactional, transactional, transactional, transactional

Methods inherited from class org.springframework.integration.dsl.EndpointSpec

assertHandler, getComponentsToRegister, id, obtainInputChannelFromFlow, obtainInputChannelFromFlow, poller, poller

Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

_this, get, getId, getObject, getObjectType, isSingleton

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

defaultDelay

public DelayerEndpointSpec defaultDelay(long defaultDelay)

Parameters:

defaultDelay - the defaultDelay.

Returns:

the endpoint spec.

See Also:

DelayHandler.setDefaultDelay(long)

ignoreExpressionFailures

public DelayerEndpointSpec ignoreExpressionFailures(boolean ignoreExpressionFailures)

Parameters:

ignoreExpressionFailures - the ignoreExpressionFailures.

Returns:

the endpoint spec.

See Also:

DelayHandler.setIgnoreExpressionFailures(boolean)

messageStore

public DelayerEndpointSpec messageStore(MessageGroupStore messageStore)

Parameters:

messageStore - the message store.

Returns:

the endpoint spec.

delayedAdvice

public DelayerEndpointSpec delayedAdvice(org.aopalliance.aop.Advice... advice)

Configure a list of Advice objects that will be applied, in nested order, when delayed messages are sent.

Parameters:

advice - the advice chain.

Returns:

the endpoint spec.

delayExpression

public DelayerEndpointSpec delayExpression(org.springframework.expression.Expression delayExpression)

delayExpression

public DelayerEndpointSpec delayExpression(java.lang.String delayExpression)

delayFunction

public <P> DelayerEndpointSpec delayFunction(java.util.function.Function<org.springframework.messaging.Message<P>,java.lang.Object> delayFunction)

Specify the function to determine delay value against Message. Typically used with a Java 8 Lambda expression:

 .<Foo>delay("delayer", m -> m.getPayload().getDate(),
            c -> c.advice(this.delayedAdvice).messageStore(this.messageStore()))
 
 

Type Parameters:

P - the payload type.

Parameters:

delayFunction - the Function to determine delay.

Returns:

the endpoint spec.