amqp/adapter/backpressure_handler.py

@@ -104,9 +104,7 @@ class BackpressureHandler:
         if not self.exchange:
 
             async def _wrap_rabbit_mq_api_init(channel):
-                _exchange = await channel.declare_exchange(
-                    name="cleverthis.clevermicro.management", type=ExchangeType.fanout
-                )
+                _exchange = await channel.get_exchange(name="cleverthis.clevermicro.management")
                 return _exchange
 
             _future = asyncio.run_coroutine_threadsafe(
@@ -130,7 +128,7 @@ class BackpressureHandler:
                         priority=0,
                         correlation_id=None,
                     )
-                    await self.exchange.publish(message=pika_message, routing_key="")
+                    await self.exchange.publish(message=pika_message, routing_key="backpressure-scaling-v1")
                     logging_info(
                         "Service Message Published to %s, msg: %s",
                         self.exchange.name,