骆驼：如何并行处理 IMAP 电子邮件？

Question

我正在尝试创建一个 Camel 路由来并行处理传入的 IMAP 消息。邮件组件应该将收到的邮件分发到不同的线程（但每封邮件都应该按顺序通过这两个处理步骤）。

像这样：

from("imap://...")
    .threads(4)
    .process(new FirstProcessor())
    .process(new SecondProcessor());

这似乎是向不同的线程发送新消息，但不是并行的（线程 n+1 在线程 n 完成后启动）。这里如何实现并行处理？

Answer 1

骆驼邮件消费者不支持此功能。它在消费者端使用相同的线程按顺序处理邮件。

您需要使用 wireTap 或以无等待模式将消息存储到 seda 队列等