Class RMQService

src/core/rabbit_mq/rmq_service.py:6–16

class RMQService:
    def __init__(self, producer: AsyncRabbitMQProducer) -> None:
        self.producer = producer

    async def send_email(self, message: EMessage) -> bool:
        return await self.producer.send_message(
            queue_name="p_email",
            action=EmailAction.send_email.value,
            message=message.to_dict(),
            exchange_name="p_email_exchange",
        )