java - 关于聚合消息

标签 java jms spring-integration spring-jms

我问一个关于我通过 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/

相关文章:

java - 我的 mp3 分割器程序出错?

java - Hibernate 枚举映射

java - JMS 池分配问题

java - JMS主题上下文查找问题

Spring 集成 RecipientListRouter 不会创建多个有效负载

java - 如何有效地对用户输入进行分类

java - Gradle 不刷新 Idea 项目中的依赖项

java - 使用 JMS 发送消息

java - 处理 Spring 集成文件的预期返回

java - Spring XD 在一个模块中转换和路由消息