#activemq
#activemq
Вопрос:
Я пытаюсь написать скрипт, который извлекает сообщения из очереди ActiveMQ и удаляет их после. Я пытался найти это в Интернете, но не смог найти никаких примеров, которые научили бы меня, как это сделать. Я хочу знать, как я могу подключиться к DLQ и как я могу его очистить? Любая помощь?
Заранее спасибо
Ответ №1:
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);