[rabbitmq-discuss] Need to close channel to get consume message

Vijay Lakshmi vijjivinay at gmail.com
Thu Jul 19 14:27:27 BST 2012


We have created,


- 1  connection and channel pool on that connection ( with 500 channels )
for subscribe

- 1 connection and channel pool on that connection ( with 500 channels )
for Consume


Our subscribe operation works fine.

However, consumer does not work. We are using QueuingConsumer like below.


Channel channel = getTheChannelFromPool();

QueueingConsumer consumer = new QueueingConsumer(channel);

channel.basicConsume(ourQueueName, false, consumer);

QueueingConsumer.Delivery delivery = consumer.nextDelivery(timeout);


//after that keep the channel back to pool



In this case, the delivery is coming as null.


Surprisingly when we close the channel, we are getting the message. ( i.e/
delivery  is not null )


Can someone please help in solving this problem.


Regards,

Vinay
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20120719/2943dc4a/attachment.htm>


More information about the rabbitmq-discuss mailing list