Spring集成：消息聚合器和事务回滚
我们的应用程序中存在以下问题。消息通过入站通道适配器传入，并使用持久消息存储在聚合器中累积。一旦释放策略中定义的条件返回true，消息将被发送到处理的下一阶段。如果在下一个处理阶段抛出异常，事务将回滚，消息将再次放入持久消息存储中。但是，事务不会将消息放回原始队列，因为消息一旦放在聚合器中就会被确认。这不是我们想要的。理想情况下，如果在处理聚合器已批处理的其中一条下游消息时发生异常，则事务只会回滚发生错误的单个消息，并将其放回原始队列。有没有使用Spring集成来实现这一点？
谢谢
共有1个答案
不是内置的；您必须自己处理错误，并重新查询失败的消息。
要在聚合器下游插入错误处理，可以添加调用网关的服务激活器（使用返回void的方法），并向其添加错误通道。
错误通道上的ErrorMessage将有一个负载，它是一个messaginegexception，具有原因和失败消息属性。
-
我想使用聚合器从两条消息中创建一条消息，但我不知道如何做到这一点。 目前，我正在从一个目录中读取两个文件，并希望将这些消息聚合为一个。 我的整个项目是这样的： 读入。拉链- 如果我可以在解压缩文件后发送一条包含两个有效负载的消息，那就太好了，但在读取后聚合就足够了。 我的拉链看起来像这样： 它将这些文件放入两个目录中，我使用FileReadingMessageSource再次从中读取它们。我还想只
-
目前，我正在与spring integration合作开发新的应用程序，并启动了poc，以了解如何处理故障案例。在我的应用程序中，spring integration将接收来自IBM mq的消息，并根据消息类型验证头信息和到不同队列的路由。传入的消息可能是批量消息，所以我使用了spring integration的拆分器和聚合器，并且对技术工作流程有很好的进展和控制。目前我面临的问题很少，我们有I
-
我有一个用例，我的消息被拆分两次，我想聚合所有这些消息。如何才能最好地实现这一点，我应该通过引入不同的序列头来聚合消息两次，还是有办法通过重写消息分组的方法在单个聚合步骤中聚合消息？
-
在我的用例中，最简单的集成组件安排是什么： 接收来自多个来源和多种格式的消息（所有消息都是JSON序列化对象）。 将消息存储在缓冲区中最多10秒（聚合） 通过不同的类属性getter（例如class1.someId（），class2.otherId（），...） 释放所有分组的消息并转换为新的聚合消息。 到目前为止（第1点和第2点），我正在使用聚合器，但不知道3）处的问题是否有现成的解决方案或者我
-
使用Spring Integr中的拆分器，我拆分了从数据库中的表中选择的数据行。每条消息完成处理后，我想像旧消息一样将每条消息聚合到一条消息中。我该怎么办？我不知道拆分器拆分了多少条消息。我只知道拆分消息头中的相关ID。即使我聚合消息，我也无法制定发布策略。 我如何解决这个问题？ 以及是否有任何方法可以使用jdbc-out站网关或jdbc-out站通道适配器一次插入多行数据，而无需使用拆分器插入每
-
我有以下应用程序要求： 从RabbitMq接收消息，然后根据一些更复杂的规则进行聚合，例如基于属性（具有预先给定的类型时间映射）和基于消息在队列中等待的现有时间（属性） 正如您在图中看到的一个用例：三条消息已经聚合并等待下一秒发布（因为当前速率为），但就在那时，以到达，并更新了，使其成为优先级最高的第一条消息。因此，在下一个选项中，我们不再发布聚合3，而是发布聚合2，因为它现在具有更高的优先级。