OpenMQ和JMX - 是否可以查询消息？
我可以通过使用JMX调用GET_DESTINATIONS操作来查询队列。有了它，我将收到队列信息（属性）。
我现在想查询存储在这个队列中的消息，这可能吗？有人可以给我指点吗？
我已经尝试过使用这段代码了
ConnectionFactory connectionFactory = new
com.sun.messaging.QueueConnectionFactory();
Connection connection = connectionFactory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Queue myQueue = session.createQueue(string);
QueueBrowser browser = session.createBrowser(myQueue);
Enumeration msgs = browser.getEnumeration();
if (!msgs.hasMoreElements()) {
System.out.println("No messages in queue");
} else {
while (msgs.hasMoreElements()) {
Message tempMsg = (Message) msgs.nextElement();
System.out.println("Message: " + tempMsg);
}
}
connection.close();
没有找到相关结果
已邀请:
1 个回复
誓猎贰
QueueBrowser browser = null; try{ Queue myQueue = session.createQueue(getName()); //Create the browser and session to be able to iterate browser = session.createBrowser(myQueue); Enumeration msgs = browser.getEnumeration();