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)