apache-camel将大量消息放入JMS中。

Question

我正在设置一个项目，在这个项目中，JMS的批量提交必须在一次尝试中完成。使用事务重新启动消息处理，因此需要思考如何将"x“消息数量推到JMS队列并执行JMS提交。

目前正在做的是创建一个JMS消息，其中一个长字符串附加了我希望一次提交的消息。然后使用拆分器在另一条路由中将消息拆分为多个。最后，使用另一条路由将消息发送到JMS (作为批量提交)。

    <route>
        <from uri="file:sample"/>
        <split streaming="true">
            <tokenize token="\n"/>
            <to uri="activemq:queue:dest"/>
        </split>
    </route>

我希望构建一个控制何时发出JMS提交的路由。

用例正在尝试从队列A读取一条消息并创建许多消息(让这个数字是"x")。然后将它们推送到队列B中。然而，我希望像DB那样进行批量提交(或批提交)。我试图提高效率，不创建到JMS的连接，并执行单独的提交。

Answer 1

我不完全明白你的问题。也许这只是一个使用什么错误处理的问题。

安装:您有一个带有事务的Camel路由，在这个路由中，您向一个或不同的队列发送多条消息。

很好的情况:路由成功完成，所有JMS消息都被传递了。

错误案例:如果您的路由遇到一个错误，比方说在处理过程中，一些消息已经“发送”了，有些不是。

在这种情况下，完全不发送消息，因为Camel做回滚，已经“发送”的消息没有真正发送，或者更确切地说，它们是尚未提交的，它们不会被提交。

重要细节：骆驼不能处理错误。如果存在，则错误不会传播到代理，因此将提交所使用的消息，JMS事务也是如此。