Un modo semplice per ottenere la lunghezza della coda di un ActiveMQ?

Question

Come ottenere la lunghezza della coda (numero di messaggi non inviati inviati alla coda) in ActiveMQ, utilizzando Java?

Answer 1

È necessario utilizzare JMX, poiché l'interfaccia della coda non fornisce tali informazioni.

Esempio di recuperare la dimensione di una specifica coda:

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

Riferimento: ActiveMQ JMX, Required MBeans

Esempio: managing ActiveMQ with JMX APIs

Answer 2

Ti piace questa;

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