From 164951e233201edcb9a8a0df29e58158355edf14 Mon Sep 17 00:00:00 2001 From: Jeniamakarchik Date: Tue, 25 Feb 2020 13:38:29 +0300 Subject: [PATCH] update consumer.py declare queue if doesn't exist --- src/consumer.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/consumer.py b/src/consumer.py index ca62b11..36ab3f4 100644 --- a/src/consumer.py +++ b/src/consumer.py @@ -89,7 +89,7 @@ if __name__ == '__main__': logger = configure_file_logger('consumer', logging_format='%(asctime)s - %(levelname)s - %(message)s') try: - channel.queue_declare(queue=conf_param['queue'], passive=True) + channel.queue_declare(queue=conf_param['queue'], durable=True, arguments={'x-max-priority': 10}) except ValueError as exc: logger.log(logging.ERROR, f'Queue {conf_param["queue"]} is not declared.') raise exc