async def METHOD_NAME(
    self,
    endpoints: Endpoints,
    request: service_pb2.ForwardMessageToDeadLetterQueueRequest,
    timeout_seconds: int,
):
    rpc_client = self.__get_rpc_client(
        endpoints, self.__client.client_config.ssl_enabled
    )
    return await rpc_client.METHOD_NAME(
        request, timeout_seconds
    )