channel.basicConsume(queue, consumer);
while (true) {
QueueingConsumer.Delivery delivery = consumer.nextDelivery();
Envelope envelope = delivery.getEnvelope();
System.out.println(envelope.getRoutingKey() + ": " + new String(delivery.getBody()));
channel.basicAck(envelope.getDeliveryTag(), false);
}
} catch (Exception ex) {
System.err.println("Main thread caught exception: " + ex);
ex.printStackTrace();
System.exit(1);