Блог

Я пытаюсь написать скрипт, который извлекает сообщения из очереди ActiveMQ и удаляет их после. Я пытался найти это в Интернете, но не смог найти никаких примеров, которые научили бы меня, как это сделать. Я хочу знать, как я могу подключиться к DLQ и как я могу его очистить? Любая помощь?

Заранее спасибо

DLQ похож на любую тему или очередь, и вы можете подписаться на него, как на любую тему или очередь, и использовать накопленные сообщения. Вот список [http://activemq.apache.org/advisory-message.html ][1]

Имя DLQ для подписки на него — ActiveMQ.DLQ если у вас его нет individualDeadLetterStrategy , вы подписываетесь и делаете свой бизнес методом onMessage . [http://activemq.apache.org/message-redelivery-and-dlq-handling.html ][2]

Новые рекомендации в 5.4 ActiveMQ.Advisory.MessageDLQd.* , доступные org.apache.activemq.advisory.AdvisorySupport.getMessageDLQdAdvisoryTopic(ActiveMQDestination);