diff --git a/awx/main/management/commands/run_callback_receiver.py b/awx/main/management/commands/run_callback_receiver.py
index 0eee2e4719..c19238a51e 100644
--- a/awx/main/management/commands/run_callback_receiver.py
+++ b/awx/main/management/commands/run_callback_receiver.py
@@ -199,7 +199,6 @@ class CallbackReceiver(object):
         return None
 
     def callback_worker(self, queue_actual):
-        self.consumer_context.destroy()
         messages_processed = 0
         while True:
             message = queue_actual.get()