Method __init__

src/core/rabbit_mq/consumer.py:18–26

(self, config: RabbitMQConfig, log: Log)

class AsyncRabbitMQConsumer:
    def __init__(self, config: RabbitMQConfig, log: Log) -> None:
        self.config = config
        self.logger = log
        self._conn: AbstractConnection | None = None
        self._channel: dict[str, AbstractChannel] = {}
        self._handlers: dict[str, MessageHandler] = {}
        self._is_initialized = False
        self._running = False
        self._shutdown_event = asyncio.Event()

    async def initialize(
        self,