BlockingConnection with heartbeat

[Mohammad Hossein Yazdani]

Hello there

I wrote a web application with flask that in the application startup I try to create a connection pool of pika.BlockingConnection and share this connection pool in my app.

**********************

global connections
connections = [pika.BlockingConnection(pika.connection.URLParameters(connection_url))
for i in range(pool_size)]
**********************

I do not close the BlockingConnections at all. I just use one of these connections in connections list and return it back to the list again.

But my problem is after creating this connection pool after 20 sec(heartbeat=20) all of my connections will be closed by rabbitmq with log: missed heartbeats from client, timeout: 20s

it seems that pika.BlockingConnection does not send heartbeat frames at all.

What  is my mistake in this implementation?

[Karl Sutt]

Hey,

I recently ran into a similar issue and looking around on the internet it seems like there are quite a few people who are experiencing the same type of problems.

The main thing you will have to take into account is the fact that your connections have to respond to RabbitMQ heartbeats every once in a while. You should use the `Connection.process_data_events()` method and call it periodically to respond to heartbeats and other "data events".

I resolved the issue for my purposes and spotted a question about a similar issue on StackOverflow. Here's my response. I've also put together a Github repo with an example implementation on top of Docker and two RabbitMQ instances.

[Luke Bakken]

Thanks for responding!

I've been out on vacation and am catching up on RabbitMQ and Pika related issues.

[Mohammad Hossein Yazdani]

Thanks a lot for your response.
Is there any open issue on this problem in pika's github repo?
If there is , would you please mention that here.
I would like to follow this issue more.

[Luke Bakken]

Hello,

No, there is no open issue at this time because this is not technically a bug in Pika.

You can follow the discussion here - https://github.com/pika/pika/discussions/1382

Thanks!