仅使用骆驼路由中的直接虚拟机请求消息传递

Question

我们如何异步处理直接虚拟机？

我有以下骆驼路线定义：

<route id="routeA">
<from uri="activemq:queue:queueA" />
<to uri="direct-vm:someProcessing" />
<to uri="direct-vm:processAsync" />
</route>

<route id="routeB">
<from uri="direct-vm:processAsync">
<threads executorServiceRef="someRef">
 <inOnly uri="direct-vm:timeTakingRoute" />
<threads>
<route>

当队列使用者使用消息并发送到routeB并使用线程DSL调用directvm:timeTakingRoute时，调用线程（即queueA）仍然等待，直到使用线程DSL创建的线程完成。

我们如何异步处理这个问题(调用者线程不应该等到使用线程DSL创建的线程完成)？

Answer 1

您可以选择seda或vm组件。使用seda时，请注意队列仅在it's CamelContext中可见。如果您想要CamelContext之间的相互通信，请使用vm组件，它是seda组件的扩展。阅读更多：seda vm

Answer 2

直接组件设计为同步http://camel.apache.org/direct-vm.html

请尝试使用seda:

<route id="routeA">
    <from uri="activemq:queue:queueA" />
    <to uri="direct-vm:someProcessing" />
    <inOnly uri="seda:processAsync" />
</route>

<route id="routeB">
    <from uri="seda:processAsync" />
    <to uri="direct-vm:timeTakingRoute" />
</route>