From 9c8a4667898a964a7fa10d0ad22efa2672eb9da1 Mon Sep 17 00:00:00 2001 From: Noloquideus Date: Mon, 11 May 2026 14:08:22 +0300 Subject: [PATCH] feat: add dureble true --- src/presentation/messaging/crypto_transfer.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/presentation/messaging/crypto_transfer.py b/src/presentation/messaging/crypto_transfer.py index 23b671c..8dacba3 100644 --- a/src/presentation/messaging/crypto_transfer.py +++ b/src/presentation/messaging/crypto_transfer.py @@ -1,4 +1,5 @@ from fastapi import Depends +from faststream.rabbit import RabbitQueue from faststream.rabbit.fastapi import RabbitMessage,RabbitRouter from pydantic import BaseModel from src.application.commands import CreateCryptoTransferCompletedCommand @@ -22,7 +23,7 @@ class CryptoTransferCompletedMessage(BaseModel): tx_hash: str | None = None -@crypto_transfer_router.subscriber(settings.RABBIT_CRYPTO_TRANSFER_COMPLETED_QUEUE) +@crypto_transfer_router.subscriber(RabbitQueue(settings.RABBIT_CRYPTO_TRANSFER_COMPLETED_QUEUE,durable=True)) async def crypto_transfer_completed_handler( msg_body: CryptoTransferCompletedMessage, message: RabbitMessage,