notifier/backend-api-internal
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Maybe don't print the URL with credentials smile
All checks were successful
Build & Publish to GHCR / build (push) Successful in 29s
Details

Browse Source
This commit is contained in:
Florian 2025-10-17 10:11:49 +02:00
parent 991a08571c
commit a7a060ac63
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/rabbitmq_handler.py
View File

@ -18,8 +18,9 @@ RABBITMQ_URL = f"amqp://{rmq_username}:{rmq_password}@{rmq_host}/{rmq_vhost}"
class RabbitMQProducer:
def __init__(self, url=RABBITMQ_URL, exchange_name=rmq_exchange):
def __init__(self, url=RABBITMQ_URL, exchange_name=rmq_exchange,rmq_host=rmq_host):
self.url = url
self.rmq_host = rmq_host
self.exchange_name = exchange_name
self.connection: aio_pika.RobustConnection | None = None
self.channel: aio_pika.RobustChannel | None = None
@ -28,10 +29,9 @@ class RabbitMQProducer:
self._flush_task: asyncio.Task | None = None
self._closing = False
self._ready = asyncio.Event()
logger.debug(f"[RabbitMQ] Initialized producer for exchange '{self.exchange_name}'")
async def connect(self):
logger.info(f"[RabbitMQ] Connecting to {self.url}...")
logger.info(f"[RabbitMQ] Connecting to {self.rmq_host}...")
self.connection = await aio_pika.connect_robust(self.url)
self.channel = await self.connection.channel(publisher_confirms=True)
self.exchange = await self.channel.declare_exchange(