我在C#中使用ActiveMQ。我不明白如何在代码中设置重新投递策略。我尝试在消费者端的代码中设置属性,但我不能理解它是否工作。
RedeliveryPolicy policy = connection.RedeliveryPolicy
policy.InitialRedeliveryDelay = 50000;
policy.MaximumRedeliveries = 5;上面我已经设置了属性,但我不知道它是正确的还是错误的。
发布于 2020-03-06 20:44:46
应该是connection.getRedeliveryPolicy();
下面是一个简单的设置示例:
RedeliveryPolicy policy = connection.getRedeliveryPolicy();
policy.setInitialRedeliveryDelay(500);
policy.setBackOffMultiplier(2);
policy.setUseExponentialBackOff(true);
policy.setMaximumRedeliveries(2);https://stackoverflow.com/questions/60560360
复制相似问题