in message_flow/commands/common/command_util.py [0:0]
def make_message_for_command( channel: str, payload: bytes, command_type: str, reply_to: str, *, headers: Dict[str, str] = {},