feat: remove auto delete flag, message delivery persistent mode

d3nbr0 · Jan 16, 2025 · 9d1db9e · 9d1db9e
1 parent 80d08d3
commit 9d1db9e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/aiocarrot/carrot.py b/aiocarrot/carrot.py
@@ -62,7 +62,7 @@ async def send(self, _cnm: str, **kwargs) -> 'ConfirmationFrameType':
         payload = ujson.dumps(message_body).encode()
 
         return await channel.default_exchange.publish(
-            message=aio_pika.Message(body=payload),
+            message=aio_pika.Message(body=payload, delivery_mode=aio_pika.DeliveryMode.PERSISTENT),
             routing_key=self._queue_name,
         )
 
@@ -191,7 +191,7 @@ async def _get_queue(self) -> 'aio_pika.abc.AbstractQueue':
 
         if not self._queue:
             channel = await self._get_channel()
-            self._queue = await channel.declare_queue(self._queue_name, durable=True, auto_delete=True)
+            self._queue = await channel.declare_queue(self._queue_name, durable=True)
 
         return self._queue