1
0
mirror of https://github.com/ansible/awx.git synced 2024-10-31 23:51:09 +03:00

Remove socket and context closure and cleanup from zeromq in the

callback receiver
This commit is contained in:
Matthew Jones 2014-10-02 09:45:45 -04:00
parent bd0d4463ef
commit 449c5026b7

View File

@ -199,7 +199,6 @@ class CallbackReceiver(object):
return None return None
def callback_worker(self, queue_actual): def callback_worker(self, queue_actual):
self.consumer_context.destroy()
messages_processed = 0 messages_processed = 0
while True: while True:
message = queue_actual.get() message = queue_actual.get()