请注意,通过执行以下操作将线程池添加到 SEDA 端点:
from("seda:stageName").thread(5).process(...)
可以取两个 BlockQueues
:一个来自 SEDA 端点,另一个来自线程池的 workqueue,这可能不是您想要的。反之,您可能想要使用线程池配置直接端点,该端点可以同时处理同步和异步处理消息。例如:
from("direct:stageName").thread(5).process(...)
您还可以使用 concurrentConsumers
选项直接配置在 SEDA 端点上处理消息的线程数。