ActiveMQ의 대기열 길이를 얻는 간단한 방법은 무엇입니까?

Question

Java를 사용하여 ActiveMQ의 대기열 길이 (대기열로 보내지는 사용되지 않은 메시지 수)를 얻는 방법은 무엇입니까?

Answer 1

대기열 인터페이스는 이러한 정보를 제공하지 않으므로 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

Answer 2

;

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