0

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

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

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

感谢您的建议

问候,

埃里克

4

1 回答 1

0

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

public Message<?> delayer(Message<?> in) throws InterruptedException {
    Thread.sleep(100);
    return in;
}
于 2020-12-22T17:17:09.907 回答