birbnetes/extractor-service
birbnetes/extractor-service
Archived
4
0
Fork 0
Code Issues Releases Activity

exchange name configurable

Browse Source
This commit is contained in:
Pünkösd Marcell 2020-04-29 23:30:07 +02:00
parent e2a7249394
commit 80331175e0
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
extractor_service/main.py
View File

@ -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...")

1
k8s/configmap.yaml
View File

@ -10,3 +10,4 @@ data:
RELEASE_ID: luna-k8s
RELEASEMODE: release
PIKA_URL: amqp://user:1wZVQnP5vy@birb-rabbitmq:5672/
PIKA_EXCHANGE_NAME: "wave"