搜索

5.3.2. 使用 JMS API 和 AMQ JMS 客户端管理代理

download PDF

要使用 JMS 消息调用管理操作,AMQ JMS 客户端必须实例化特殊管理队列。

步骤

  1. 创建一个 QueueRequestor,将消息发送到管理地址并接收回复。
  2. 创建 消息
  3. 使用帮助程序类 org.apache.activemq.artemis.api.jms.management.JMSManagementHelper,用管理属性填充消息。
  4. 使用 QueueRequestor 发送消息。
  5. 使用帮助程序类 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");
Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

© 2024 Red Hat, Inc.