in message_flow/commands/consumer/command_dispatcher.py [0:0]
def __init__(
self,
command_handlers: CommandHandlers,
message_consumer: IMessageConsumer,
message_producer: IMessageProducer,
*,
serializer: ISerializer = JsonMapper(),
deserializer: IDeserializer = JsonMapper()