public final class DelayerEndpointSpec extends ConsumerEndpointSpec<DelayerEndpointSpec,DelayHandler>
ConsumerEndpointSpec for a DelayHandler.adviceChaincomponentToRegister, endpointFactoryBean, handlerlogger, PARSER, target| Modifier and Type | Method and Description |
|---|---|
DelayerEndpointSpec |
defaultDelay(long defaultDelay) |
DelayerEndpointSpec |
delayedAdvice(Advice... advice)
Configure a list of
Advice objects that will be applied, in nested order,
when delayed messages are sent. |
DelayerEndpointSpec |
delayExpression(Expression delayExpression) |
DelayerEndpointSpec |
delayExpression(String delayExpression) |
<P> DelayerEndpointSpec |
delayFunction(java.util.function.Function<Message<P>,Object> delayFunction)
Specify the function to determine delay value against
Message. |
DelayerEndpointSpec |
ignoreExpressionFailures(boolean ignoreExpressionFailures) |
DelayerEndpointSpec |
messageStore(MessageGroupStore messageStore) |
advice, async, autoStartup, order, phase, poller, requiresReply, sendTimeout, transactional, transactional, transactional, transactional, transactionalassertHandler, doGet, getComponentsToRegister, id, poller, poller_this, get, getId, getObject, getObjectType, isSingletonpublic 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(Advice... advice)
Advice objects that will be applied, in nested order,
when delayed messages are sent.advice - the advice chain.public DelayerEndpointSpec delayExpression(Expression delayExpression)
public DelayerEndpointSpec delayExpression(String delayExpression)
public <P> DelayerEndpointSpec delayFunction(java.util.function.Function<Message<P>,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.