def initialize()

in message_flow/commands/consumer/command_dispatcher.py [0:0]

• 6 lines of code
• 1 McCabe index (conditional complexity)

    def initialize(self) -> None:
        self._message_consumer.subscribe(
            self._command_handlers.channels,
            self.message_handler,
            queue=self._command_handlers.queue,
        )