From 80331175e0701ac69e5f524a73b5f8507105aded Mon Sep 17 00:00:00 2001 From: marcsello Date: Wed, 29 Apr 2020 23:30:07 +0200 Subject: [PATCH] exchange name configurable --- extractor_service/main.py | 2 +- k8s/configmap.yaml | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/extractor_service/main.py b/extractor_service/main.py index 0ef31bd..fe44c18 100644 --- a/extractor_service/main.py +++ b/extractor_service/main.py @@ -41,7 +41,7 @@ def main(): queue_declare_result = channel.queue_declare(queue='', exclusive=True) queue_name = queue_declare_result.method.queue - channel.queue_bind(exchange='wave-extract', queue=queue_name) + channel.queue_bind(exchange=os.environ['PIKA_EXCHANGE_NAME'], queue=queue_name) channel.basic_consume(queue=queue_name, on_message_callback=message_callback, auto_ack=True) logging.info("Connection complete! Listening to messages...") diff --git a/k8s/configmap.yaml b/k8s/configmap.yaml index aedcc56..7ae5204 100644 --- a/k8s/configmap.yaml +++ b/k8s/configmap.yaml @@ -9,4 +9,5 @@ data: SENTRY_DSN: https://6d243347cf9f4fc6a54759c3eb34e864@sentry.kmlabz.com/8 RELEASE_ID: luna-k8s RELEASEMODE: release - PIKA_URL: amqp://user:1wZVQnP5vy@birb-rabbitmq:5672/ \ No newline at end of file + PIKA_URL: amqp://user:1wZVQnP5vy@birb-rabbitmq:5672/ + PIKA_EXCHANGE_NAME: "wave" \ No newline at end of file