1

ブラウザを使用してキューからメッセージを見ようとしています。コードは次のようなものです:

javax.naming.InitialContext ctx = new javax.naming.InitialContext();
javax.jms.QueueConnectionFactory qcf = (javax.jms.QueueConnectionFactory)ctx.lookup('java:/XAConnectionFactory');

javax.jms.QueueConnection connection = qcf.createQueueConnection('admin', 'admin'); // qcf.createQueueConnection();
javax.jms.QueueSession session = connection.createQueueSession(false, javax.jms.Session.AUTO_ACKNOWLEDGE);
connection.start();

// It is a "special" queue and it is not looked up from JNDI but constructed directly
javax.jms.Queue queue = (javax.jms.Queue)ctx.lookup('/queue/myQueue');

javax.jms.QueueBrowser browser = session.createBrowser(queue);

TreeMap<Date, javax.jms.Message> messageMap = new TreeMap<Date, javax.jms.Message>();
int counter = 0;

Enumeration<javax.jms.Message> enumeration = browser.getEnumeration();
while (enumeration.hasMoreElements()) {
  counter++;
  javax.jms.Message message = enumeration.nextElement();
  messageMap.put(new Date(message.getJMSTimestamp()), message);
}

connection.stop();
ctx.close();
session.close();
connection.close();

問題は、jmx-console を調べて listMessagesAsJSON を呼び出すと、大量のメッセージが表示されるにもかかわらず、常に列挙で 1 つのメッセージしか取得できないことです。

私が間違っていることについてのアイデアはありますか?

4

2 に答える 2

1

consumer-window-size を設定すると (アプリで行ったように)、バグhttps://issues.jboss.org/browse/HORNETQ-691にヒットする可能性があるようです。

于 2013-10-29T14:24:55.743 に答える