Guest User

Untitled

a guest
Apr 25th, 2012
27
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.98 KB | None | 0 0
  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. }
Advertisement
Add Comment
Please, Sign In to add comment