Below is my rabbitmq snippet. I am running long running task, connection is getting closed though my task continue to run in the background. But, when connection is getting closed, older msg get requeued and picked by another worker. How to avoid connection getting closed? I do see this thread talks about using threading: Handling long running tasks in pika / RabbitMQ

I have 3 consumers that connect with the broker. How can I import a external config file which contains the queue parameters so that I dont have to re-write them in all the python files.