Get exchange name of rabbitmq from environment variable.

sunmao-dx · Oct 29, 2022 · 2fa146d · 2fa146d
1 parent 46478b9
commit 2fa146d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)