Don't like ads? PRO users don't see any ads ;-)
Guest

Untitled

By: a guest on Apr 25th, 2012  |  syntax: None  |  size: 0.98 KB  |  hits: 11  |  expires: Never
download  |  raw  |  embed  |  report abuse  |  print
Text below is selected. Please press Ctrl+C to copy to your clipboard. (⌘+C on Mac)
  1. How to synchronize onMessage() of MessageListener
  2. public void listAllJMS_Messages()
  3.     {
  4.         try {
  5.             ObjectName objectName=new ObjectName("jboss.messaging.destination:name=DLQ,service=Queue");
  6.             List ls = (List) server.invoke(objectName, "listAllMessages" , null, null);
  7.             List<javax.jms.Message> messages=(List<javax.jms.Message>)server.invoke(objectName, "listAllMessages" , null, null);
  8.             int count=0;
  9.             for(javax.jms.Message msg : messages) {
  10.                 System.out.println((++count)+"t"+msg.getJMSMessageID());
  11.                if(msg.getJMSType() != null && msg.getJMSType().equalsIgnoreCase("Text")) {
  12.                 TextMessage text = (TextMessage)msg;
  13.                 System.out.println(text.getText());
  14.                }
  15.             }
  16.         } catch (Exception e) {
  17.             // TODO Auto-generated catch block
  18.             e.printStackTrace();
  19.         }
  20.  
  21.         // System.out.println((++count)+"t"+msg.getText());
  22.     }