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

Prevent premature garbage collection
All checks were successful
Build & Publish to GHCR / build (push) Successful in 1m2s
Details

Browse Source
This commit is contained in:
Florian 2025-11-07 18:24:26 +01:00
parent d21f56a2ae
commit c16c637135
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/rabbitmq_handler.py
View File

@ -65,9 +65,11 @@ class RabbitMQConsumer:
await self.channel.declare_queue(self.dlq_queue_name, durable=True)
metrics.start_metrics_server(port=9000)
asyncio.create_task(metrics.update_queue_gauge(self.channel, self.queue_name))
asyncio.create_task(metrics.update_queue_gauge(self.channel, self.retry_queue_name))
asyncio.create_task(metrics.update_queue_gauge(self.channel, self.dlq_queue_name))
await asyncio.gather(
metrics.update_queue_gauge(self.channel, self.queue_name),
metrics.update_queue_gauge(self.channel, self.retry_queue_name),
metrics.update_queue_gauge(self.channel, self.dlq_queue_name),
)
logger.info("[RabbitMQ] Connected, exchange, retry, and DLQ queues ready.")