使用apache camel执行路由关闭逻辑

Question

我最近开始使用Apache Camel，我遇到的一个问题是在选择的路由上正确地执行关闭逻辑。由于关闭逻辑在不同的路由之间会有所不同，所以Camel的RoutePolicy是最有意义的。这里有一个例子来说明我为什么要这么做。

public class ProcessingRouteBuilder extends RouteBuilder {
  private ProducerTemplate prodTemplate;

  public class ProcessingRouteBuilder(ProducerTemplate aProdTemplate) {
    prodTemplate = aProdTemplate; 
  }

  @Override
  public void configure() {
    from("direct://processing")
      .routePolicy(new RoutePolicySupport() {
        @Override
        public void onStop(Route route) {
          super.onStop(route);
          prodTemplate.sendBody("direct://shutdownRoute", "msg");
        }
      })
      .process(ex -> // Do stuff)

    from("direct://shutdownRoute")
      .log("Running shutdown A route body - ${body}");
  }
}

运行这个会给我一个DirectConsumerNotAvailableException，我已经使用了seda和vm（我不打算与多个上下文交互，但我已经尝试过了），两者都没有异常，但关机路由从未被击中。我有一些问题

1. 我可能错误地使用了生产者模板？看起来不像是在创建交换。
2. 一旦启动了Shutdown挂钩，我甚至可以使用ProducerTemplate吗？我不确定Camel是如何执行关闭的，但它不允许发送新消息，以及是否在发送时关闭路由可用，这是有意义的。

需要注意的一件事（这里没有处理）是确保在处理路由完成对其队列中所有消息的处理之后执行关闭路由。我不完全确定在没有更多inflight消息之后是否调用onStop（）方法，如果不是，如何执行它？

我认为另一种方法是在每条路由的开头使用when/choice并发送某种类型的关机通知或消息，但这似乎更加笨拙。

谢谢伙计们！

Answer 1

要以编程方式关闭路由，还可以使用控制总线EIP。

但是，“停止”逻辑并不清楚，因为当处理路由停止时，您希望向shutdownroute发送一条消息，但是如果停止是因为您正在关闭骆驼上下文，那么shutdownroute可能已经停止了。