diff --git a/pyinfra/queue/queue_manager.py b/pyinfra/queue/queue_manager.py
index 5021114..a60159b 100644
--- a/pyinfra/queue/queue_manager.py
+++ b/pyinfra/queue/queue_manager.py
@@ -58,10 +58,7 @@ class QueueManager(object):
         self._channel.queue_declare(self._output_queue, arguments=args, auto_delete=False, durable=True)
 
     def _close_channel(self):
-        self._channel.close()
-
-        if environ.get("CLOSE_CONNECTION", False) == "True":
-            self._connection.close()
+        self._connection.close()
 
     def start_consuming(self, process_message_callback: Callable):
         self._open_channel()