我问一个关于我通过 Spring 集成和 Spring 实现的 JMS 的简单问题,但我遇到了一种情况,请告诉我,假设我在队列中收到 5000 条消息,我想聚合为一组 20 条消息,然后转发它,这意味着我想要某种聚合,它将从 5000 条消息中获取 20 条消息,然后转发这 20 条消息,请告知如何实现这一点。
我也经历过这种模式.. http://www.eaipatterns.com/Aggregator.html
最佳答案
Spring Integration 引用手册的这一部分应该提供您需要的所有信息: http://static.springsource.org/spring-integration/docs/2.2.x/reference/htmlsingle/#aggregator
基本上,您需要一个在消息组大小达到 20 时返回 true 的发布策略,并且您需要一个仅将所有消息视为位于同一组中的相关性策略(除非您确实有其他一些组成员资格指示符)。
希望有帮助。 -标记
关于java - 关于聚合消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/15425554/