apache-camel - 仅在 Camel route 使用 direct-vm 请求消息传递

Question

我们如何异步处理direct-vm？

我有以下 Camel 路线定义:

<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 调用 direct-vm:timeTakingRoute 时，调用线程 queueA 仍然等待直到使用线程 DSL 创建线程完成。

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

Answer 1

直接组件被设计为同步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>