forked from LiveCarta/BookConverter
update consumer.py
declare queue if doesn't exist
This commit is contained in:
@@ -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
|
||||
|
||||
Reference in New Issue
Block a user