RPC server re-connect issue

[cloud-rocket]

I am implementing an RPC server (with robust connection) that should restore the broker connection if it's lost.

The reconnect attempt is not working unless I am monkey patching the internal aio-pika RPC.initialize code to create a non-exclusive result_queue:

        self.result_consumer_tag = await self.result_queue.consume(
            self.on_result_message, exclusive=False, no_ack=True,
        )

Any idea what should be the proper way to do it?
Thanks!

[mosquito]

Set lower heartbeat and server will be forget about lost client faster.