获取ActiveMQ队列长度的简单方法是什么？

如何使用Java在ActiveMQ中获取队列长度（发送到队列的未使用消息的数量）？获取ActiveMQ队列长度的简单方法是什么？

2011-10-10 user705414

您必须使用JMX，因为Queue接口不提供此类信息。参考：[ActiveMQ JMX]（http://activemq.apache.org/jmx.html），[必需的MBeans]（http://activemq.apache.org/jmx-support.html）示例：[使用JMX管理ActiveMQ APIs]（http://www.consulting-notes.com/2010/08/monitoring-and-managing-activemq-with.html） – Dag

您必须使用JMX，因为队列接口不提供此类信息。

检索特定队列的大小的实施例

：

// connection 
String url = "service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi"; 
JMXConnector connector = JMXConnectorFactory.connect(new JMXServiceURL(url)); 
MBeanServerConnection connection = connector.getMBeanServerConnection(); 
// get queue size 
ObjectName nameConsumers = new ObjectName("org.apache.activemq:type=Broker,brokerName=localhost,destinationType=Queue,destinationName=myqueue"); 
DestinationViewMBean mbView = MBeanServerInvocationHandler.newProxyInstance(connection, nameConsumers, DestinationViewMBean.class, true); 
long queueSize = mbView.getQueueSize();

参考：ActiveMQ JMX，Required MBeans

实施例：managing ActiveMQ with JMX APIs

来源

2011-10-10 15:22:58 Dag

感谢提示，但我使用了下一个ObjectName：“org.apache.activemq：BrokerName = localhost，Type = Queue，Destination = queueName“和QueueViewMBean类来获取queueViewMBean。一般 - 方法是一样的 –

筛选;

QueueBrowser browser = session.createBrowser(queue); 
Enumeration enu = browser.getEnumeration(); 
List list = new ArrayList();   
    while (enu.hasMoreElements()) { 
    TextMessage message = (TextMessage) enu.nextElement();   
    list.add(message.getText()); 
    } 
System.out.println("Size " + list.size());

来源

2011-10-11 06:00:26 Ratha

注意，除非你增加maxPageSize和memoryLimit它将只浏览你最多400条消息：http://betterlogic.com/roger/2012/06/activemq-browse-all-messages – rogerdpack

你会读消费者的所有经纪人消息只是简单地计算它，真的？ – deFreitas

获取ActiveMQ队列长度的简单方法是什么？

回答

相关问题