[rabbitmq-discuss] Channel thread safety in Java Client

Fri Jul 17 14:18:13 BST 2009

tsuraan wrote:
> I could do that.  I'd just have to keep track of which channel each
> message came from.

FYI, any subclass of DefaultConsumer has getChannel(), which returns the
channel that the Consumer is associated with. So, for example, given a
QueueingConsumer "qc":

 while (true) {
  QueueingConsumer.Delivery delivery = qc.nextDelivery();
  System.out.println("Message: " + new String(delivery.getBody()));
  qc.getChannel().basicAck(delivery.getEnvelope().getDeliveryTag(),
                           false);
 }

Regards,
  Tony
-- 
 [][][] Tony Garnock-Jones     | Mob: +44 (0)7905 974 211
   [][] LShift Ltd             | Tel: +44 (0)20 7729 7060
 []  [] http://www.lshift.net/ | Email: tonyg at lshift.net