6.3.2. 使用 JMS API 和 AMQ JMS 客户端管理代理
若要利用 JMS 消息调用管理操作，AMQ JMS 客户端必须实例化特殊的管理队列。
流程
-
创建一个
QueueRequestor，以发送消息到管理地址并接收回复。 -
创建
消息. -
使用 helper 类
org.apache.activemq.artemis.api.jms.management.JMSManagementHelper填写消息及管理属性。 -
使用
QueueRequestor发送消息。 -
使用 helper 类
org.apache.activemq.artemis.api.jms.management.JMSManagementHelper，从管理回复检索操作结果。
例 6.2. 查看队列中的消息数
本例演示了如何使用 JMS API 查看 JMS 队列 exampleQueue 中的消息数量：
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");