damanukyan/pay-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: add dureble true

Browse Source
This commit is contained in:
Daniil Manukian
2026-05-11 14:08:22 +03:00
parent d7ccddc72c
commit 9c8a466789
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/presentation/messaging/crypto_transfer.py
View File

@@ -1,4 +1,5 @@
from fastapi import Depends from fastapi import Depends
from faststream.rabbit import RabbitQueue
from faststream.rabbit.fastapi import RabbitMessage,RabbitRouter from faststream.rabbit.fastapi import RabbitMessage,RabbitRouter
from pydantic import BaseModel from pydantic import BaseModel
from src.application.commands import CreateCryptoTransferCompletedCommand from src.application.commands import CreateCryptoTransferCompletedCommand
@@ -22,7 +23,7 @@ class CryptoTransferCompletedMessage(BaseModel):
tx_hash: str | None = None 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( async def crypto_transfer_completed_handler(
msg_body: CryptoTransferCompletedMessage, msg_body: CryptoTransferCompletedMessage,
message: RabbitMessage, message: RabbitMessage,