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,