2

我在出站适配器之前有一个聚合器(为了批处理请求)。

我想确保,当出站适配器发生故障时,聚合器停止发布消息,反过来,背压会向上传播集成流,直到最终出站适配器重新上线。

在我看来,这似乎是 EIP 中理想的模式,虽然我很确定它涉及队列支持的通道,但我不确定这是如何实现的,原因有几个。

A)如果适配器的失败开始是由异常引起的(实际上我@retryable在出站适配器上使用),那么重新排队消息的“正确”方法是什么?

B)我假设聚合器的收割线程将尊重下游队列的“背压”。也就是说,在这种情况下,如何告诉聚合器停止消费来自上游的消息?

4

0 回答 0