如何保持Mule进程，直到JMS消耗完成处理

Question

我的mule流中有JMS，其中生产者从缓存中读取记录，放入队列，消费者消费消息并进行进一步处理。以下是理解流程。

服务1（从文件读取数据）-

在上面的流中，从JMS组件，流成为异步，因此一旦生产者将所有记录放入队列中，响应就会返回给客户端，说进程已完成，但消费者可能仍然会使用消息。

我想保持来自生产者的流程以发回响应，直到消费者消费所有消息。

你知道如何实现吗？

Answer 1

您可以使用交换模式值作为请求-响应，以便流将等待来自 JMS 的响应。

Answer 2

如上所述，轮询完成状态可以正常工作，但仍存在某些事务在等待时间后未完成的风险，或在所有消息处理完毕后等待很长时间的风险。

根据本练习的最终目标，您也许可以利用Mule batch，它已经实现了将入站请求分割成单独的消息，在一个或多个消费者线程中处理消息，跟踪已处理和剩余的块，并在处理完所有数据后报告结果/执行最后的步骤。

如果您不能使用batch，并且需要将处理过的消息重组到一个列表或映射中，那么您可以让收集聚合器来完成通过关联ID跟踪消息和设置超时的工作。

实现它的简单DIY方法是为JMS发布组件构建某种调度程序逻辑。它将向JMS提交所有消息，然后等待每个使用者/工作线程（通过单独的JMS队列）使用具有相同关联ID的完成消息进行响应。然后，调度器将跟踪内存或永久存储中所有提交/处理的消息，并在批处理中的最后一条消息被确认后或通过预定义的超时时间进行响应。这与Mule batch已经做的非常接近。

干杯！马頔

Answer 3

由于异步获取确切线程的副本并独立处理，因此创建者可能会将消息放入队列中的速度与使用者实际能够使用它之前一样快。
我能想到的一种方法是将消息放入队列的过程，方法是在它之前放置一个 sleep（）。
您可以使用 Groovy 组件并在其中使用 sleep（） 来保持流动或减慢流程。
例如，如果将以下内容放入：

<scripting:component doc:name="Groovy">
  <scripting:script engine="Groovy"><![CDATA[
    sleep(10000);
    return message.payload;]]>
  </scripting:script>
</scripting:component>

在将消息放入队列之前，进程将稍微减慢，并将保持流10000毫秒，直到另一端的消费者实际消费它。