Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- List<QueueEntry> items = new ArrayList<QueueEntry>();
- GetResponse response = null;
- long msgtime = 0;
- try {
- do {
- response = channel.basicGet(queuename, true);
- if (response == null) {
- //no message. k.
- System.out.println("No msg");
- } else {
- AMQP.BasicProperties props = response.getProps();
- byte[] body = response.getBody();
- msgtime = props.getTimestamp().getTime();
- System.out.println("Msgtime:" + msgtime);
- items.add(new QueueEntry(body));
- //channel.basicAck(response.getEnvelope().getDeliveryTag(), true);
- }
- } while (response != null && msgtime <= curtime);
- }
- catch (IOException e) {
- e.printStackTrace();
- }
- return items;
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement