Проверка ActiveMQ с помощью консоли JMX -jConsole

Question

Как просмотреть сообщение, которое было потреблено потребителем в ActiveMQ JMS с помощью консоли JMX -jConsole?

Answer 1

, чтобы сделать это, Вы можете просматривать темы ActiveMQ.Advisory.MessageConsumed.Topic.YourTopicName или для очереди с помощью JConsole или VisualVM, это возможно Экспертного сообщение http://activemq.apache.org/advisory-message.html и вам необходимо включить это в брокерской конфигурации путем добавления этого:

<destinationPolicy> 
     <policyMap> 
      <policyEntries> 
      <!-- http://activemq.apache.org/advisory-message.html --> 
      <policyEntry topic=">" advisoryForConsumed="true" /> 
      <policyEntry queue=">" advisoryForConsumed="true" /> 
      </policyEntries> 
     </policyMap> 
    </destinationPolicy> 

код для просмотра консультативных сообщений.

 Destination advisoryDestination = AdvisorySupport.getMessageDeliveredAdvisoryTopic(destination); 
     Destination advisoryDestination = AdvisorySupport.getMessageDiscardedAdvisoryTopic(destination); 
     Destination advisoryDestination = AdvisorySupport.getMessageConsumedAdvisoryTopic(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; 
        ConsumerInfo consumerInfo = (ConsumerInfo) aMsg.getDataStructure(); 
       } catch (JMSException e) { 
        log.error("Failed to process message: " + msg); 
       } 
      } 
     }