From 90c87038b6e5480b299151b4504b91f56ff2b961 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Torma=20Krist=C3=B3f?= Date: Sat, 24 Oct 2020 00:58:28 +0200 Subject: [PATCH] do not use exclusive queue --- cnn_classification_service/main.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cnn_classification_service/main.py b/cnn_classification_service/main.py index 5dd700d..f12f422 100644 --- a/cnn_classification_service/main.py +++ b/cnn_classification_service/main.py @@ -58,7 +58,7 @@ def main(): channel = connection.channel() channel.exchange_declare(exchange=os.environ['PIKA_INPUT_EXCHANGE'], exchange_type='direct') - queue_declare_result = channel.queue_declare(queue='cnnqueue', exclusive=True) + queue_declare_result = channel.queue_declare(queue='cnnqueue', exclusive=False) queue_name = queue_declare_result.method.queue channel.queue_bind(exchange=os.environ['PIKA_INPUT_EXCHANGE'],routing_key='feature', queue=queue_name)