ActivemMQ, как указать deadletterqueue для сообщения, превышающего повторную доставку через код - PullRequest
Новая
       13

ActivemMQ, как указать deadletterqueue для сообщения, превышающего повторную доставку через код

0 голосов
/ 14 марта 2019

Как указать deadletterqueue для сообщения, превышающего повторную доставку через код? Я попробовал что-то вроде ниже. но я не нашел, как это сделать с помощью кода Java.

Любые намеки или предложения приветствуются! 

                RedeliveryPolicy queuePolicy = new RedeliveryPolicy();
                queuePolicy.setInitialRedeliveryDelay(0);
                queuePolicy.setRedeliveryDelay(10000);
                queuePolicy.setUseExponentialBackOff(false);
                queuePolicy.setMaximumRedeliveries(3);

                PolicyEntry policy = new PolicyEntry();
                IndividualDeadLetterStrategy strategy = new IndividualDeadLetterStrategy();
                strategy.setProcessNonPersistent(true);
                strategy.setQueuePrefix("test.from.DLQ.");

                RedeliveryPolicyMap map = connectionFactory.getRedeliveryPolicyMap();
                map.put(new ActiveMQQueue("test.>"), queuePolicy);

С настройкой ниже (в файле activemq.xml см. Скриншот вложения enter image description here) Set Time to Live не работает, Установить DeadLetterQueue для превышения максимальной повторной доставки также не работает Настройки приведены ниже документов http://activemq.apache.org/message-redelivery-and-dlq-handling.html http://activemq.apache.org/timestampplugin.html

...