6.6. 使用消息计数器

先决条件

• 代理上必须启用消息计数器。

  更多信息请参阅 第 6.6.2 节 “启用消息计数器”。

流程

• 使用管理 API 检索消息计数器。

  // Retrieve a connection to the broker's MBeanServer.
  MBeanServerConnection mbsc = ...
  JMSQueueControlMBean queueControl = (JMSQueueControl)MBeanServerInvocationHandler.newProxyInstance(mbsc,
     on,
     JMSQueueControl.class,
     false);
  
  // Message counters are retrieved as a JSON string.
  String counters = queueControl.listMessageCounter();
  
  // Use the MessageCounterInfo helper class to manipulate message counters more easily.
  MessageCounterInfo messageCounter = MessageCounterInfo.fromJSON(counters);
  System.out.format("%s message(s) in the queue (since last sample: %s)\n",
  messageCounter.getMessageCount(),
  messageCounter.getMessageCountDelta());

  Copy to Clipboard Toggle word wrap

其他资源

• 有关消息计数器的更多信息，请参阅 第 6.4.3 节 “队列管理操作”。