如何从Mule批量发送消息到ActiveMQ

Question

在 mule 中，我有一个流接收带有 500mb xml 文件的 InputStream。

我想按照一定的规则拆分 xml 文件。

结果是我需要发送到 ActiveMQ 队列的 390000 条消息。

如果我在一个事务中发送所有消息，ActiveMQ 将给出内存不足异常。

如果我不使用事务，它会成功，但会慢很多。

批量发送 1000 条消息的最佳方式是什么？

我可以使用标准组件吗？

我正在使用 ActiveMQ 5.13 和 Mule 3.7

谢谢

Answer 1

我认为您正在寻找批量提交doc here。 一旦收集到指定数量的记录，该组件将执行内部流组件。 示例：

<batch:commit size="100" doc:name="Batch Commit">
    <!-- Put here all the message processor you want for example the active mq one -->
</batch:commit>

请注意，事务仅允许在步骤级别进行，因此也允许在我认为这正是您正在寻找的提交块中。

脚注：批处理提交处理器只允许在批处理步骤中。

希望对你有帮助

问候