Merge pull request #2345 from robkooper/monitor-fix

fix pika issues
PecanProject · May 8, 2019 · 1676d5c · 1676d5c
2 parents 17e8518 + a8c13ef
commit 1676d5c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/docker/monitor/monitor.py b/docker/monitor/monitor.py
@@ -299,11 +299,11 @@ def rabbitmq_monitor():
     channel.exchange_declare(exchange='models', exchange_type='fanout', durable=True)
 
     # create anonymous queue
-    result = channel.queue_declare(exclusive=True)
+    result = channel.queue_declare('', exclusive=True)
     channel.queue_bind(exchange='models', queue=result.method.queue)
 
     # listen for messages
-    channel.basic_consume(on_message_callback=callback, queue=result.method.queue, no_ack=True)
+    channel.basic_consume(on_message_callback=callback, queue=result.method.queue)
 
     channel.start_consuming()