[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