spring-integration - 放慢入站通道

Question

我们使用 spring 集成将消息从一个代理 (amqp | jms) 传输到另一个代理。

我们希望减慢来自输入通道的消息的消耗：<int-amqp: inbound-channel-adapter>或者 <int-jms: message-driven-channel-adapter（例如通过添加节奏）以免使远程队列饱和，给它处理消息的时间。

另一个约束是尊重输出队列上消息的顺序。

感谢您的建议

问候，

埃里克

Answer 1

您可以简单地<int:service-activator .../>在入站适配器之后将 a 添加到流中，方法是

public Message<?> delayer(Message<?> in) throws InterruptedException {
    Thread.sleep(100);
    return in;
}