我正在编写一个消费者作为我的自定义Camel组件的一部分 . 我希望为后续组件提供并行处理我的消息的机会,以提高吞吐量 . 这意味着我应该尽快发送 message 2
- 也就是说,无需等待 message 1
的反馈循环 .
我在我的消费者中做了以下事情:
while (isRunAllowed()) {
Exchange exchange = ...; // retrieve and prepare next message, ordered
getAsyncProcessor().process(exchange, new AsyncCallback() {
public void done(boolean doneSync) {
...
}
}
}
如您所见,所有 getAsyncProcessor().process()
调用都按特定顺序完成 . 当消息到达路径中下一个组件的 生产环境 者时,是否会保留此顺序?