Class EmailWorker

src/cmd/email_worker.py:17–46

class EmailWorker(AsyncCLICommandBase):
    async def execute(self, loop: asyncio.AbstractEventLoop) -> int:
        try:
            from src.cmd.worker.email.send_email import SendEmailHandler
            from src.core.rabbit_mq.worker import RMWorker

            worker = RMWorker(
                consumer=self.container.rmq_consumer(), queue="p_email", exchange="p_email_exchange", log=self.log
            )

            await worker.initialize(loop=loop, handlers=[SendEmailHandler(container=self.container)])

            try:
                self.log.info("🚀 Starting email worker...")
                await worker.start()
            except asyncio.CancelledError:
                self.log.info("🚦 Email worker cancelled, shutting down gracefully...")
                return 0
            except Exception as e:
                self.log.error(f"🛑 Failed to start RabbitMQ worker: {e}")
                return 1
            finally:
                await worker.stop()
                self.log.info("🛑 Email worker stopped")

            return 0

        except Exception as e:
            self.log.error(f"Email worker execution failed: {e}")
            return 1


if __name__ == "__main__":