in message_flow/commands/consumer/command_message.py [0:0]
def __init__( self, message_id: str, command: C, correlation_headers: Dict[str, str], message: IMessage,