Fix rabbitmq exchange config

safe-global · Dec 17, 2024 · e2a2ba9 · e2a2ba9
1 parent 31a60e9
commit e2a2ba9
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/app/datasources/queue/queue_provider.py b/app/datasources/queue/queue_provider.py
@@ -49,7 +49,7 @@ async def _connect(self, loop: AbstractEventLoop) -> None:
 
         channel = await self._connection.channel()
         self._exchange = await channel.declare_exchange(
-            settings.RABBITMQ_AMQP_EXCHANGE, ExchangeType.FANOUT
+            settings.RABBITMQ_AMQP_EXCHANGE, ExchangeType.FANOUT, durable=True
         )
         self._events_queue = await channel.declare_queue(
             settings.RABBITMQ_DECODER_EVENTS_QUEUE_NAME, durable=True

diff --git a/app/tests/datasources/queue/test_queue_provider.py b/app/tests/datasources/queue/test_queue_provider.py
@@ -35,7 +35,7 @@ async def test_consume(self):
         message = "Test message"
         channel = await self.provider._connection.channel()
         exchange = await channel.declare_exchange(
-            settings.RABBITMQ_AMQP_EXCHANGE, aio_pika.ExchangeType.FANOUT
+            settings.RABBITMQ_AMQP_EXCHANGE, aio_pika.ExchangeType.FANOUT, durable=True
         )
 
         await exchange.publish(