0

抱歉，我回答了我自己的问题——它实际上只是 SEDA，当我看到“BlockingQueue”时，我假设 SEDA 会阻塞，直到队列被读取……这当然是无稽之谈。SEDA 完全是我所需要的。已回答问题

我遇到了一个让我很头疼的问题，我们连接到的公司为我提供了一个自定义端点，但是端点保持对提要的心跳，当它发送超过一定大小的消息时，它们需要很长时间在其阻塞和心跳丢失并且连接断开的路由上进行处理

显然，这类似于在非图形线程上处理事件以保持平稳运行。但我不确定如何在骆驼中实现这一目标。本质上，我想将结果排队并将它们放在单独的线程上。

from( "custom:endpoint" )
.process( MyProcesor )
.to( "some-endpoint")
4

1 回答 1

0

正如建议的那样， camel-seda是一种执行异步/多线程处理的简单方法，请注意阻塞队列仅在内存中（如果 VM 停止，则会丢失等）。如果您需要有保证的消息传递支持，请使用camel-jms

于 2013-04-08T18:32:40.870 回答