def initialize()

in message_flow/events/subscriber/domain_event_dispatcher.py [0:0]

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

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