diff --git a/khl/receiver.py b/khl/receiver.py index ad02e89..8a04ad0 100644 --- 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():