#15 - merge in the backpressure fix - get the exchange the right way

amqp/adapter/backpressure_handler.py

@@ -221,8 +221,8 @@ 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
 
@@ -246,7 +246,9 @@ 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,