内部循环队列发布的替代方法

Question

我想使用 camelContext 蓝图以异步方式在队列中发布数据。

完整上下文：

<camelContext id="xContext" xmlns="http://camel.apache.org/schema/blueprint">
    <route id="notifPublisher">
        <from id="notifService" uri="cxfrs:bean:xRequestService"/>
        <inOnly id="toRequestQueue" uri="activemq:queue:{{data.queue}}?jmsMessageType=Text"/>
        <setHeader headerName="Content-Type" id="setContentType"/>
    </route>
    <route id="xReceiver">
        <from id="dataqueue" uri="activemq:queue:{{data.queue}}?jmsMessageType=Text"/>
        <log id="logDataQueue_" message="Data/DatAs ${body}"/>
        <bean id="fetchUsers" method="fetchUsers" ref="dataProcessor"/>
        <bean id="checkDataInList" method="checkDataInList" ref="dataProcessor"/>
        <loop doWhile="true" id="_loop1">
            <simple>${header.mailMap} != 'EMPTY'</simple>
            <bean id="sendInQueuePerData" method="sendInQueuePerData" ref="dataProcessor"/>
            <to id="emailqueue" uri="activemq:queue:{{email.queue}}?jmsMessageType=Text"/>
        </loop>
    </route>
</camelContext>

电子邮件

队列开始由其他电子邮件处理器处理。emailProcessor 正在向 SMTP 发送电子邮件。

问题是数据处理器被阻止，直到它将完成所有输入数据。一旦将数据发送到队列，就不应阻止它。

Answer 1

这里不需要 for 循环。将 checkDataInList 的输出传递到拆分器中，然后传递到电子邮件处理器。

这将是非阻塞的，并且是更骆驼的做事方式。