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)