(self, loop: asyncio.AbstractEventLoop, handlers: list[MessageHandler])
| 13 | self.logger = log |
| 14 | |
| 15 | async def initialize(self, loop: asyncio.AbstractEventLoop, handlers: list[MessageHandler]) -> None: |
| 16 | await self.consumer.initialize(loop=loop) |
| 17 | for handler in handlers: |
| 18 | self.consumer.register_handler(handler) |
| 19 | self.logger.info("🚀 RabbitMQ worker initialized successfully") |
| 20 | |
| 21 | async def start(self) -> None: |
| 22 | try: |
no test coverage detected