Advertisement
Guest User

rabbitnq problem

a guest
Jun 1st, 2010
447
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 5 0.97 KB | None | 0 0
  1.  List<QueueEntry> items = new ArrayList<QueueEntry>();
  2.  
  3.  
  4.         GetResponse response = null;
  5.         long msgtime = 0;
  6.  
  7.         try {
  8.  
  9.             do {
  10.  
  11.                 response = channel.basicGet(queuename, true);
  12.                
  13.  
  14.  
  15.                 if (response == null) {
  16.                     //no message. k.
  17.                     System.out.println("No msg");
  18.                 } else {
  19.                     AMQP.BasicProperties props = response.getProps();
  20.                     byte[] body = response.getBody();
  21.                     msgtime = props.getTimestamp().getTime();
  22.                     System.out.println("Msgtime:" + msgtime);
  23.                     items.add(new QueueEntry(body));
  24.                     //channel.basicAck(response.getEnvelope().getDeliveryTag(), true);
  25.  
  26.                 }
  27.             } while (response != null && msgtime <= curtime);
  28.         }
  29.         catch (IOException e) {
  30.             e.printStackTrace();
  31.         }
  32.         return items;
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement