8.9. Delayer

delayer 是一个处理器，可让您对传入的消息应用 相对 时间延迟。

您可以使用 delay （） 命令将 相对时间延迟 （以毫秒为单位）添加到传入的消息。例如，以下路由将所有传入的信息延迟 2 秒：

from("seda:a").delay(2000).to("mock:result");

或者，您可以使用表达式指定时间延迟：

from("seda:a").delay(header("MyDelay")).to("mock:result");

跟随 delay （） 的 DSL 命令被解释为 delay （） 的子clauses。因此，在某些上下文中，需要通过插入 end （） 命令来终止 delay （）的子目录。例如，当 delay （） 出现在 onException （） 子句中时，您将按如下方式终止它：

from("direct:start")
    .onException(Exception.class)
        .maximumRedeliveries(2)
        .backOffMultiplier(1.5)
        .handled(true)
        .delay(1000)
            .log("Halting for some time")
            .to("mock:halt")
        .end()
    .end()
    .to("mock:result");

以下示例演示了 XML DSL 中的延迟：

<camelContext xmlns="http://camel.apache.org/schema/spring">
    <route>
        <from uri="seda:a"/>
        <delay>
            <header>MyDelay</header>
        </delay>
        <to uri="mock:result"/>
    </route>
    <route>
        <from uri="seda:b"/>
        <delay>
            <constant>1000</constant>
        </delay>
        <to uri="mock:result"/>
    </route>
</camelContext>

您可以将表达式与 bean 结合使用来确定延迟，如下所示：

from("activemq:foo").
  delay().expression().method("someBean", "computeDelay").
  to("activemq:bar");

其中 bean 类可以定义如下：

public class SomeBean {
  public long computeDelay() {
     long delay = 0;
     // use java code to compute a delay value in millis
     return delay;
 }
}

您可以让延迟程序 使用非块异步延迟，这意味着 Apache Camel 计划在以后要执行的任务。该任务负责处理路由的后者部分（延迟后）。这允许调用者线程取消阻塞和服务进一步传入的消息。例如：

from("activemq:queue:foo")
    .delay(1000)
    .asyncDelayed()
    .to("activemq:aDelayedQueue");

相同的路由可以使用 XML DSL 编写，如下所示：

<route>
   <from uri="activemq:queue:foo"/>
   <delay asyncDelayed="true">
       <constant>1000</constant>
   </delay>
   <to uri="activemq:aDealyedQueue"/>
   </route>

delayer 模式支持以下选项：