5.3.2. 使用 JMS API 和 AMQ JMS 客户端管理代理
要使用 JMS 消息调用管理操作，AMQ JMS 客户端必须实例化特殊管理队列。
步骤
-
创建一个
QueueRequestor，将消息发送到管理地址并接收回复。 -
创建
消息。 -
使用帮助程序类
org.apache.activemq.artemis.api.jms.management.JMSManagementHelper，用管理属性填充消息。 -
使用
QueueRequestor发送消息。 -
使用帮助程序类
org.apache.activemq.artemis.api.jms.management.JMSManagementHelper从管理回复中检索操作结果。
例 5.2. 查看队列中的消息数量
本例演示了如何使用 JMS API 查看 JMS 队列 示例Queue 中的消息数量：
Queue managementQueue = ActiveMQJMSClient.createQueue("activemq.management");
QueueSession session = ...
QueueRequestor requestor = new QueueRequestor(session, managementQueue);
connection.start();
Message message = session.createMessage();
JMSManagementHelper.putAttribute(message, "queue.exampleQueue", "messageCount");
Message reply = requestor.request(message);
int count = (Integer)JMSManagementHelper.getResult(reply);
System.out.println("There are " + count + " messages in exampleQueue");