Method __init__

src/core/rabbit_mq/worker.py:9–13

(self, consumer: AsyncRabbitMQConsumer, queue: str, exchange: str, log: Log)

class RMWorker:
    def __init__(self, consumer: AsyncRabbitMQConsumer, queue: str, exchange: str, log: Log) -> None:
        self.consumer = consumer
        self.queue = queue
        self.exchange = exchange
        self.logger = log

    async def initialize(self, loop: asyncio.AbstractEventLoop, handlers: list[MessageHandler]) -> None:
        await self.consumer.initialize(loop=loop)