Bất kỳ cách đơn giản nào để có được độ dài hàng đợi của ActiveMQ?

Question

Làm thế nào để có được độ dài hàng đợi (số lượng thư chưa gửi được gửi đến hàng đợi) trong ActiveMQ, sử dụng Java?

Answer 1

Bạn phải sử dụng JMX, vì giao diện Hàng đợi không cung cấp thông tin như vậy.

Ví dụ về lấy kích thước của một hàng đợi cụ thể:

// 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(); 

tham khảo: ActiveMQ JMX, Required MBeans

Ví dụ: managing ActiveMQ with JMX APIs

Answer 2

Như thế này;

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());