Início / coding / Perguntas / 79288243
Accepted
burki
Asked: 2024-12-17 22:23:01 +0800 CST

É possível obter uma única mensagem do ActiveMQ Artemis por meio do Jolokia JMX?

  • 772

Tento obter uma única mensagem de Artemis através do Jolokia JMX, mas não consigo encontrar uma maneira de filtrar por JMSMessageID.

Versão do corretor: Red Hat AMQ 7.11.7

Minha melhor tentativa atualmente é:

https://broker/console/jolokia/exec/org.apache.activemq.artemis:broker=!%22amq-broker!%22,component=addresses,address=!%22ExpiryQueue!%22,subcomponent=queues,routing-type=!%22anycast!%22,queue=!%22ExpiryQueue!%22/browse(java.lang.String)/JMSmessageID=!%2215232235223!%22

Ele chama o browse(String filter)método em QueueControl, com o argumento JMSmessageID="15232235223", mas o filtro não funciona. Quando executo essa requisição, eu só pego todas as mensagens da fila.

Quando omito as aspas duplas ao redor do ID da mensagem, não obtenho resultados.

Li em outra resposta que a filtragem de cabeçalhos de mensagens não é possível (apenas para propriedades), o que parece estranho.

No entanto, alguma sugestão de como obter uma única mensagem por ID de mensagem? Obrigado

jms

1 respostas

  1. Best Answer

    Há algumas coisas que precisamos ter em mente aqui...

    1. O "ID da mensagem" que você vê no console da web é realmente uma maneira do próprio broker rastrear a mensagem. Ele está sujeito a alterações sob certas circunstâncias, então não é válido para uso como um identificador de mensagem exclusivo de um aplicativo cliente. Se você estiver usando um cliente JMS, então JMSMessageIDdeve ser suficiente para isso. Isso é representado como "ID do usuário" no console da web.
    2. Usar JMSMessageIDem uma consulta funcionaria se você estivesse usando um cliente JMS. No entanto, o console da web do ActiveMQ Artemis não usa um cliente JMS ao navegar por mensagens. Ele simplesmente usa a Core API . Portanto, você precisa usar uma expressão de filtro principal , a saber AMQUserID.
    3. JMSMmessageIDrequer começar ID:conforme observado no JavaDoc .
    4. A sintaxe do filtro Core usa a mesma sintaxe SLQ 92 que os seletores JMS. Essa sintaxe não coloca literais de string entre aspas duplas (ie "). Você deve usar aspas simples (ie ') em vez disso. Conforme observado no JavaDoc relevante :

      Uma string literal é colocada entre aspas simples...

    Juntando tudo isso...Algo assim deve funcionar para você:

    https://broker/console/jolokia/exec/org.apache.activemq.artemis:broker=!%22amq-broker!%22,component=addresses,address=!%22ExpiryQueue!%22,subcomponent=queues,routing-type=!%22anycast!%22,queue=!%22ExpiryQueue!%22/browse(java.lang.String)/AMQUserID='ID:8dfdf33e-bc84-11ef-9ea4-3ce1a1d12939'
    • 1

relate perguntas