7
A
回答
6
這是你可以指望沒有消息的隊列中的
public static void main(String[] args) throws Exception
{
// get the initial context
InitialContext ctx = new InitialContext();
// lookup the queue object
Queue queue = (Queue) ctx.lookup("queue/queue0");
// lookup the queue connection factory
QueueConnectionFactory connFactory = (QueueConnectionFactory) ctx.
lookup("queue/connectionFactory");
// create a queue connection
QueueConnection queueConn = connFactory.createQueueConnection();
// create a queue session
QueueSession queueSession = queueConn.createQueueSession(false,
Session.AUTO_ACKNOWLEDGE);
// create a queue browser
QueueBrowser queueBrowser = queueSession.createBrowser(queue);
// start the connection
queueConn.start();
// browse the messages
Enumeration e = queueBrowser.getEnumeration();
int numMsgs = 0;
// count number of messages
while (e.hasMoreElements()) {
Message message = (Message) e.nextElement();
numMsgs++;
}
System.out.println(queue + " has " + numMsgs + " messages");
// close the queue connection
queueConn.close();
}
+0
我實際上運行這個例子,由於某種原因,當我在隊列上有5000條消息時,消息數顯示爲400 –
+0
How do you say隊列中有5000條消息。 – sunleo
+0
我在我的ActiveMQ控制檯 –
5
使用JmsTemplate的
public int getMessageCount(String messageSelector)
{
return jmsTemplate.browseSelected(messageSelector, new BrowserCallback<Integer>() {
@Override
public Integer doInJms(Session s, QueueBrowser qb) throws JMSException
{
return Collections.list(qb.getEnumeration()).size();
}
});
}
相關問題
- 1. JMS隊列接收消息?
- 2. 替換jms隊列中的消息
- 3. JMS隊列中的延遲消息
- 4. 如何統計窗口消息隊列中的消息?
- 5. WMI查詢來統計MSMQ毒性隊列中的消息數
- 6. Glassfish 3.1 JMS隊列監測和統計
- 7. Java內部消息隊列/ JMS
- 8. 發送XML消息給SONIC JMS隊列
- 9. 在JMS隊列上發佈消息?
- 10. 在JMS隊列上測試消息
- 11. JMS消息 - 與隊列關聯
- 12. JMS隊列消息接收訂單
- 13. 錯誤從JMS消息獲取隊列
- 14. JMS消息回滾到隊列
- 15. JMS消息重新傳遞到隊列
- 16. 消息隊列系統
- 17. 系統V消息隊列
- 18. 消息系統中的表對隊列
- 19. 如何獲取jms隊列中待處理消息的數量
- 20. JMS統計主題域中未決消息的數量
- 21. 在JMS隊列上計算消息時出現奇怪行爲
- 22. JMS消息生產者不會將消息發送到隊列
- 23. 消息隊列設計
- 24. 使用多線程從JMS隊列中消費消息
- 25. JMS - 消費者在消費之前瀏覽隊列消息
- 26. JMS/Glassfish - 不消耗隊列消息的MDB
- 27. JMS大橋現有的隊列中的消息
- 28. 系統-V的消息隊列PHP C++
- 29. 帶jms的消息計數器Hornetq
- 30. 如何識別Spring Jms消息監聽器中的消息隊列名稱
你可以在某些情況下使用JMX(取決於JMS實現的) – user1516873
我明白了,'的ActiveMQ '標籤。 ActiveMQ的例子http://java.dzone.com/articles/managing-activemq-jmx-apis – user1516873