java - 如何在 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>

我希望每个消费者路由异步请求 1000 倍的 生产者_CUSTOMER_INTERACTIONS_ISSUES_RLATIONSHIPS_Topic 的模拟内容，但是，现在，它是同步的，如下所示:

我在 Camel 文档中阅读了有关 SEDA 组件的信息，但没有任何关于如何在蓝图中使用它的示例:(

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 以强制其异步运行。

我真的不知道这是否是野兽的方法。如果其他人有更好的答案，请发布以帮助=)