Skip to content

Commit 9d1db9e

Browse files
committed
feat: remove auto delete flag, message delivery persistent mode
1 parent 80d08d3 commit 9d1db9e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

aiocarrot/carrot.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ async def send(self, _cnm: str, **kwargs) -> 'ConfirmationFrameType':
6262
payload = ujson.dumps(message_body).encode()
6363

6464
return await channel.default_exchange.publish(
65-
message=aio_pika.Message(body=payload),
65+
message=aio_pika.Message(body=payload, delivery_mode=aio_pika.DeliveryMode.PERSISTENT),
6666
routing_key=self._queue_name,
6767
)
6868

@@ -191,7 +191,7 @@ async def _get_queue(self) -> 'aio_pika.abc.AbstractQueue':
191191

192192
if not self._queue:
193193
channel = await self._get_channel()
194-
self._queue = await channel.declare_queue(self._queue_name, durable=True, auto_delete=True)
194+
self._queue = await channel.declare_queue(self._queue_name, durable=True)
195195

196196
return self._queue
197197

0 commit comments

Comments
 (0)