fix(RabbitMQReceiver): add start log

TWT233 · Oct 19, 2023 · 752e057 · 752e057
1 parent c2a8a33
commit 752e057
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/khl/receiver.py b/khl/receiver.py
@@ -149,6 +149,9 @@ async def start(self):
         channel = await connection.channel()
         await channel.set_qos(prefetch_count=10)
         queue = await channel.declare_queue(self.queue)
+
+        log.info('[ init ] launched')
+
         async with queue.iterator() as queue_iter:
             async for message in queue_iter:
                 async with message.process():