【发布时间】:2016-08-02 21:56:33
【问题描述】:
当我向主题发送消息时,为什么处理器会获得 10 次交换?这是我的代码。
public class RouteTest extends RouteBuilder {
public void configure() throws Exception {
from("activemq:topic:Topic.ansyncMessage").process(new Processor() {
public void process(Exchange exchange) throws Exception {
System.out.println(exchange.getIn().getBody());
}
});
}
}
【问题讨论】:
-
请使用代码标签将您的代码添加到问题中,而不是链接到屏幕截图,人们将更有可能提供帮助。
-
因为您可能已经启动了 10 次程序。
标签: apache-camel activemq