(self)
| 19 | self.logger.info("🚀 RabbitMQ worker initialized successfully") |
| 20 | |
| 21 | async def start(self) -> None: |
| 22 | try: |
| 23 | await self.consumer.consume( |
| 24 | queue_name=self.queue, exchange_name=self.exchange, durable=True, exclusive=False, auto_delete=False |
| 25 | ) |
| 26 | except Exception as e: |
| 27 | self.logger.error(f"🛑 Failed to start RabbitMQ worker: {e}") |
| 28 | await self.stop() |
| 29 | raise |
| 30 | |
| 31 | async def stop(self) -> None: |
| 32 | await self.consumer.close() |