setup queues for autodeletion

Author: Andrei Neagu

packages/service-library/src/servicelib/rabbitmq/_client_rpc.py

@@ -49,7 +49,7 @@ async def _rpc_initialize(self) -> None:
         self._channel = await self._connection.channel()
 
         self._rpc = aio_pika.patterns.RPC(self._channel)
-        await self._rpc.initialize(durable=True)
+        await self._rpc.initialize(durable=True, auto_delete=True)
 
     async def close(self) -> None:
         with log_context(

packages/service-library/tests/deferred_tasks/test__utils.py

@@ -57,7 +57,7 @@ async def _() -> AsyncIterator[RabbitBroker]:
 
 @pytest.fixture
 def rabbit_exchange() -> RabbitExchange:
-    return RabbitExchange("test_exchange", durable=True)
+    return RabbitExchange("test_exchange", durable=True, auto_delete=True)
 
 
 async def _assert_call_count(
@@ -257,7 +257,10 @@ async def test_fan_out_exchange_message_delivery(
     handler_2_call_count = Mock()
 
     fan_out_exchange = RabbitExchange(
-        "test_fan_out_exchange", type=ExchangeType.FANOUT, durable=True
+        "test_fan_out_exchange",
+        type=ExchangeType.FANOUT,
+        durable=True,
+        auto_delete=True,
     )
 
     @rabbit_broker.subscriber(queue="handler_1", exchange=fan_out_exchange, retry=True)