我正在尝试创建一个Camel路由,它将并行处理传入的IMAP消息 . 邮件组件应将传入的邮件分发到不同的线程(但每条消息应按顺序通过两个处理步骤) .
像这样的东西:
from("imap://...")
.threads(4)
.process(new FirstProcessor())
.process(new SecondProcessor());
这似乎将新消息发送到不同的线程,但不是并行(线程n 1在线程n完成后开始) . 我怎样才能在这里实现并行处理?
1 回答
camel-mail消费者不支持此功能 . 它使用消费者方面的相同线程按顺序处理邮件 .
您需要使用wireTap或在无等待模式下将消息存储到seda队列等 .