async def METHOD_NAME(
    self, message: Union[bytes, str, Dict[str, Any]],
    binary: bool = False, locked: bool = True
) -> None:
    metadata = {'binary': binary}
    if binary:
        self.comm.send({}, metadata=metadata, buffers=[message])
    else:
        self.comm.send(message, metadata=metadata)