spring-integration - 放慢入站通道
问题描述
我们使用 spring 集成将消息从一个代理 (amqp | jms) 传输到另一个代理。
我们希望减慢来自输入通道的消息的消耗:<int-amqp: inbound-channel-adapter>
或者 <int-jms: message-driven-channel-adapter
(例如通过添加节奏)以免使远程队列饱和,给它处理消息的时间。
另一个约束是尊重输出队列上消息的顺序。
感谢您的建议
问候,
埃里克
解决方案
您可以简单地<int:service-activator .../>
在入站适配器之后将 a 添加到流中,方法是
public Message<?> delayer(Message<?> in) throws InterruptedException {
Thread.sleep(100);
return in;
}
推荐阅读
- asp.net-mvc - 如何在 ASP.NET Core 3.0 的另一个程序集中使用控制器?
- c# - 为什么我的 JSON 数据没有使用 Unitys JsonUtility 正确反序列化?
- excel - 从用 python 中的 pandas 和 tkinter 打开的 excel 表中捕获数据
- php - PHP 脚本未通过 cron 作业运行
- mysql - 当外键在另一张表上时,如何从另一张表中级联删除?
- c - 连续操作 inkstrorkecontainer.clear() 和 addstrokes() 导致 UWP 中的 EXCEPTION
- ios - 即使在提交所有更改并重新打开 Xcode 之后,Git 仍显示未提交的更改 - Git Tower
- javascript - Firebase以选择形式显示数据 - 角度
- testing - 如何在 Leiningen 中声明测试范围依赖项?
- node.js - 我突然无法使用 Typescript 在 node.js 中安装 Express