0

我正在使用 C# 中的 ActiveMQ。我不明白如何在代码中设置重新交付政策。我试图在消费者端的代码中设置属性,但我无法理解它是否有效。

RedeliveryPolicy policy = connection.RedeliveryPolicy
policy.InitialRedeliveryDelay = 50000;
policy.MaximumRedeliveries = 5;

上面我已经设置了属性,但我不知道它是否正确。

4

1 回答 1

0

应该是 connection.getRedeliveryPolicy();

下面是一个简单的设置示例:

RedeliveryPolicy policy = connection.getRedeliveryPolicy();
policy.setInitialRedeliveryDelay(500);
policy.setBackOffMultiplier(2);
policy.setUseExponentialBackOff(true);
policy.setMaximumRedeliveries(2);
于 2020-03-06T12:44:45.820 回答