达到队列大小后的 Spring 集成触发器

Question

我目前正在使用 Spring Integration，应用程序对从 MQ 收到的每条消息执行以下操作

1. 阅读留言
2. 变换
3. 将转换后的消息发布到 API

为了提高吞吐量，我想改成以下

1. 阅读留言
2. 变换
3. 发布到队列频道
4. 使用 10 条转换消息调用批处理 api

<channel id="apiChannel"> <queue size="10"/> </channel>

谁能指出我如何实现这个触发器，即等待队列深度为 10 或从第一个插入的 msg 开始的时间是 2 秒，然后再调用具有 10 条消息的服务激活器？

Answer 1

使用聚合器（使用发布策略size == 10）而不是队列通道。相关策略可以是一个简单的常数，因为您只是在聚合大小。