public final class DelayerEndpointSpec extends ConsumerEndpointSpec<DelayerEndpointSpec,DelayHandler>
ConsumerEndpointSpec
for a DelayHandler
.adviceChain
componentsToRegister, endpointFactoryBean, handler
logger, PARSER, target
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) |
advice, async, autoStartup, doGet, notPropagatedHeaders, order, phase, poller, requiresReply, role, sendTimeout, taskScheduler, transactional, transactional, transactional, transactional, transactional
assertHandler, getComponentsToRegister, id, poller, poller
_this, get, getId, getObject, getObjectType, isSingleton
public DelayerEndpointSpec defaultDelay(long defaultDelay)
defaultDelay
- the defaultDelay.DelayHandler.setDefaultDelay(long)
public DelayerEndpointSpec ignoreExpressionFailures(boolean ignoreExpressionFailures)
ignoreExpressionFailures
- the ignoreExpressionFailures.DelayHandler.setIgnoreExpressionFailures(boolean)
public DelayerEndpointSpec messageStore(MessageGroupStore messageStore)
messageStore
- the message store.public DelayerEndpointSpec delayedAdvice(org.aopalliance.aop.Advice... advice)
Advice
objects that will be applied, in nested order,
when delayed messages are sent.advice
- the advice chain.public DelayerEndpointSpec delayExpression(org.springframework.expression.Expression delayExpression)
public DelayerEndpointSpec delayExpression(java.lang.String delayExpression)
public <P> DelayerEndpointSpec delayFunction(java.util.function.Function<org.springframework.messaging.Message<P>,java.lang.Object> delayFunction)
Message
.
Typically used with a Java 8 Lambda expression:
.<Foo>delay("delayer", m -> m.getPayload().getDate(),
c -> c.advice(this.delayedAdvice).messageStore(this.messageStore()))
P
- the payload type.delayFunction
- the Function
to determine delay.