如何在Apache Camel Blueprint中使用异步路由

Question

我有一个必须异步使用的路由，我使用一个直接组件将其作为别名引用。

    <route id="producer_CUSTOMER_INTERACTIONS_ISSUES_RELATIONSHIPS_Topic">
        <from uri="direct:test"/>
        <pollEnrich aggregateOnException="false" id="pollEnrich1" timeout="-1">
            <constant>file:mock/customer-interactions-issues-relationships?noop=true&amp;idempotent=false</constant>
        </pollEnrich>
        <to uri="kafka:customer-interactions-issues-relationships?brokers=localhost:9092"/>
    </route>

该路线必须由以下人员消耗：

<route id="1"><from uri="timer://foo?fixedRate=true&amp;period=1&amp;repeatCount=1000"/><to uri="direct:test"/></route>
<route id="2"><from uri="timer://foo?fixedRate=true&amp;period=1&amp;repeatCount=1000"/><to uri="direct:test"/></route>
<route id="3"><from uri="timer://foo?fixedRate=true&amp;period=1&amp;repeatCount=1000"/><to uri="direct:test"/></route>
<route id="4"><from uri="timer://foo?fixedRate=true&amp;period=1&amp;repeatCount=1000"/><to uri="direct:test"/></route>

我希望每个使用者路由异步地请求1000xproducer_customer_interactions_issues_rlationships_topic的模拟内容，但是，现在，它是同步的，如下所示：

Answer 1

为了帮助其他需要这样做的人，我使用以下方法解决了这个问题：

<route id="1"><from uri="timer://foo?fixedRate=true&amp;period=1&amp;repeatCount=1000&amp;delay=-1"/><to uri="direct:test"/></route>

我只是添加了delay=-1来强制它异步运行。

我真的不知道是不是野兽的做法。如果其他人有更好的答案，请张贴到帮助=)