我在camel中设置了以下路由。我已经在这里发布了完整的代码。在ProcessorTwo被调用之后,我期望ProcessorOnComplete被调用,但它根本没有被触发。我在这里错过了什么?公共类CamelRoute扩展了RouteBuilder { public void configure() throws Exception {
from
,这是否是将消息发送回同一个队列时的预期行为?, if not ready, throw NotReadyEception我尝试过的另外两种方法至少不会产生重复,from(rabbitmq:pollingQueue?如果设置延迟(常量(数字)),则引发以下错误:
Exception in thread "main" org.ap
在我们的设置中,我们使用了camel、jms、spring和hibernate,并且我们有很多类似的消息。所以它们需要由一个由Spring创建的处理器来处理。但是我可以看到,处理器只运行一次。我也检查了线程转储和日志,所以我现在可以说,这是一个事实,软件没有以正确的方式扩展。 //Process the me