Apache Camel：窃听和优雅的关机

Question

当我调试我的Camel应用程序时，我意识到路由的正常关闭会忽略由wiretap()触发的未完成任务。

如果我有如下的路由定义：

from("direct:start")
    .wireTap("bean:myWireTapBean")
    .to("mock:result");

我在MyWireTapBean中设置了一个调试断点（即挂起wireTap的异步处理），然后camelcontext.stoproute(routeId)调用将产生以下日志消息：

11:36:12.352 [Thread-1] INFO  o.a.camel.spring.SpringCamelContext - Apache Camel 2.19.1 (CamelContext: camel-1) is shutting down
11:36:12.352 [Thread-1] INFO  o.a.c.impl.DefaultShutdownStrategy - Starting to graceful shutdown 1 routes (timeout 300 seconds)
11:36:12.352 [Camel (camel-1) thread #6 - ShutdownTask] INFO  o.a.c.impl.DefaultShutdownStrategy - Route: route1 shutdown complete, was consuming from: direct://myRoute
11:36:12.352 [Thread-1] INFO  o.a.c.impl.DefaultShutdownStrategy - Graceful shutdown of 1 routes completed in 0 seconds
11:36:12.478 [Thread-1] WARN  o.a.c.impl.DefaultInflightRepository - Shutting down while there are still 1 inflight exchanges.
11:36:12.478 [Thread-1] INFO  o.a.camel.spring.SpringCamelContext - Apache Camel  2.19.1 (CamelContext: camel-1) uptime 1.411 seconds
11:36:12.478 [Thread-1] INFO  o.a.camel.spring.SpringCamelContext - Apache Camel 2.19.1 (CamelContext: camel-1) is shutdown in 0.126 seconds

Answer 1

是的，当前的窃听实现没有考虑到活动任务，如果它们没有被路由。

我记录了一张票，以添加对延迟关闭窃听EIP（如果它有飞行任务）的支持:https://issues.apache.org/jira/browse/camel-11539

解决办法是创建一个路由，例如Direct，然后调用该路由，然后在此路由中调用bean，然后在关闭Camel时，Direct路由将进行飞行交换，因此等待它完成。