[rabbitmq-discuss] Consumer get blocked after all connections exhausted.

Timon Wang timon86.wang at gmail.com
Fri May 16 02:42:32 BST 2014


It seems that Consumer will get blocked after all connections exhausted.
Some rabbitmqctl commands such as `rabbitmqctl list_queues` and
`rabbitmqctl list_consumers` will get stucked as well.

Here is an example to demonstrate that:
https://gist.github.com/timonwong/238f2379d1acbbd4ef0a
After all connections are exhausted, consumer will get blocked after
several seconds, `rabbitmqadmin list queues` will indicate that there was
unacknowledged messages in the queue:

+-------+-----------+-------------+----------------------+-----------+---------+------------------------+----------+----------+----------------+-------------------------+------------------+--------+---------+
| vhost |   name    | auto_delete | consumer_utilisation | consumers |
durable | exclusive_consumer_tag |  memory  | messages | messages_ready |
messages_unacknowledged |       node       | policy |  state  |
+-------+-----------+-------------+----------------------+-----------+---------+------------------------+----------+----------+----------------+-------------------------+------------------+--------+---------+
| /     | test.msgs | False       | 0.105861902008       | 1         | True
   |                        | 74966600 | 46906    | 45664          | 1242
                 | rabbit at localhost |        | running |
+-------+-----------+-------------+----------------------+-----------+---------+------------------------+----------+----------+----------------+-------------------------+------------------+--------+---------+


I've tried Python kombu library with both pyamqp and librabbitmq as
transport driver.

Am I doing something wrong? Or is it a expected behavior?

My environment

Server side:
CentOS 6.3 64bit
RabbitMQ: 3.3.1

Client side:
CentOS 6.3 64bit
Python 2.7.6
Kombu 3.0.16

Thanks in advance.

Regards,
Timon
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20140516/217daccf/attachment.html>


More information about the rabbitmq-discuss mailing list