From 2fa146d18ce32a3731016edf0ea213df374f0df3 Mon Sep 17 00:00:00 2001 From: Guoqiang QI Date: Sat, 29 Oct 2022 16:30:06 +0800 Subject: [PATCH] Get exchange name of rabbitmq from environment variable. --- common/producer.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/common/producer.py b/common/producer.py index 452e6cf..f037071 100644 --- a/common/producer.py +++ b/common/producer.py @@ -6,7 +6,7 @@ RMQ_USER = os.environ.get('RMQ_USER', 'event-platform') RMQ_PASS = os.environ.get('RMQ_PASS', 'opensource_at_123') QUEUE_NAME = os.environ.get('RMQ_QUEUE_NAME', 'gitee_data_processing') -EXCHANGE_NAME = 'delayed_exchange' +EXCHANGE_NAME = os.environ.get('EXCHANGE_NAME', 'delayed_exchange') credentials = pika.PlainCredentials(RMQ_USER, RMQ_PASS)