Истерируйте по ненастоящим сообщениям activemq в ActiveMQ.Advisory.Expired.Queue

Question

Iam создает приложение на activemq, где iam отправляет сообщение от производителя, где мой режим доставки NON_PERSISTENT (iam не имеет отношения к режиму доставки PERSISTENT, и я знаю он будет сохранен в DLQ, который не является моим дизайном) и установил время для сообщения, используя файл production.setTimeToLive (2000). Поскольку функциональность говорит, что сообщение истечет через 2 секунды.

Я вижу, что старые сообщения помещён в ActiveMQ.Advisory.Expired.Queue в теме секции ActiveMQ консоли администратора т.е. http://localhost:8161/admin/topics.jsp.

Мой вопрос, как я итерацию по ActiveMQ.Advisory.Expired.Queue так, что я могу получить доступ к MESSAGEID в выдыхаемом примере message.Any кода будет большой.

Answer 1

Подписка на адрес ActiveMQ.Advisory.Expired.Queue похож на любую тему и возвращает ActiveMQMessage. Есть объекты DataStructure (ConsumerInfo, ProducerInfo, ConnectionInfo ...), которые можно получить с помощью метода getDataStructure ActiveMQMessage.

док http://activemq.apache.org/advisory-message.html

пример:

Destination advisoryDestination = AdvisorySupport.getExpiredQueueMessageAdvisoryTopic(destination) 
MessageConsumer consumer = session.createConsumer(advisoryDestination); 
consumer.setMessageListener(this); 

public void onMessage(Message msg){ 
    String messageId = msg.getJMSMessageID(); 
    String orignalMessageId = msg.getStringProperty(org.apache.activemq.advisory.AdvisorySupport.MSG_PROPERTY_MESSAGE_ID); 
    if (msg instanceof ActiveMQMessage){ 
     try { 
      ActiveMQMessage aMsg = (ActiveMQMessage)msg; 
      ProducerInfo prod = (ProducerInfo) aMsg.getDataStructure(); 
     } catch (JMSException e) { 
      log.error("Failed to process message: " + msg); 
     } 
    } 
}