From b718ef12d398b7c5af15f1fabab4ba71a7901832 Mon Sep 17 00:00:00 2001 From: marcsello Date: Wed, 18 Aug 2021 15:53:05 +0200 Subject: [PATCH] Added routing key --- storage_service_feeder/main.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/storage_service_feeder/main.py b/storage_service_feeder/main.py index 335adc7..37ad45a 100644 --- a/storage_service_feeder/main.py +++ b/storage_service_feeder/main.py @@ -99,7 +99,7 @@ def main(): queue_declare_result = channel.queue_declare(queue=str(uuid.uuid4()), exclusive=False) queue_name = queue_declare_result.method.queue - channel.queue_bind(exchange=Config.PIKA_SAMPLE_CACHE_EXCHANGE, queue=queue_name) + channel.queue_bind(exchange=Config.PIKA_SAMPLE_CACHE_EXCHANGE, routing_key='cache', queue=queue_name) channel.basic_qos(prefetch_count=1)