本文整理了Java中org.I0Itec.zkclient.ZkClient.retryUntilConnected()方法的一些代码示例，展示了ZkClient.retryUntilConnected()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZkClient.retryUntilConnected()方法的具体详情如下：
包路径：org.I0Itec.zkclient.ZkClient
类名称：ZkClient
方法名：retryUntilConnected

ZkClient.retryUntilConnected介绍

暂无

代码示例

代码示例来源：origin: com.101tec/zkclient

protected boolean exists(final String path, final boolean watch) {
  return retryUntilConnected(new Callable<Boolean>() {
    @Override
    public Boolean call() throws Exception {
      return _connection.exists(path, watch);
    }
  });
}

代码示例来源：origin: com.101tec/zkclient

public void watchForData(final String path) {
  retryUntilConnected(new Callable<Object>() {
    @Override
    public Object call() throws Exception {
      _connection.exists(path, true);
      return null;
    }
  });
}

代码示例来源：origin: com.github.sgroschupf/zkclient

protected List<String> getChildren(final String path, final boolean watch) {
  return retryUntilConnected(new Callable<List<String>>() {
    @Override
    public List<String> call() throws Exception {
      return _connection.getChildren(path, watch);
    }
  });
}

代码示例来源：origin: com.101tec/zkclient

protected List<String> getChildren(final String path, final boolean watch) {
  return retryUntilConnected(new Callable<List<String>>() {
    @Override
    public List<String> call() throws Exception {
      return _connection.getChildren(path, watch);
    }
  });
}

代码示例来源：origin: com.101tec/zkclient

public boolean delete(final String path, final int version) {
  try {
    retryUntilConnected(new Callable<Object>() {
      @Override
      public Object call() throws Exception {
        _connection.delete(path, version);
        return null;
      }
    });
    return true;
  } catch (ZkNoNodeException e) {
    return false;
  }
}

代码示例来源：origin: com.github.sgroschupf/zkclient

protected boolean exists(final String path, final boolean watch) {
  return retryUntilConnected(new Callable<Boolean>() {
    @Override
    public Boolean call() throws Exception {
      return _connection.exists(path, watch);
    }
  });
}

代码示例来源：origin: com.github.sgroschupf/zkclient

public void watchForData(final String path) {
  retryUntilConnected(new Callable<Object>() {
    @Override
    public Object call() throws Exception {
      _connection.exists(path, true);
      return null;
    }
  });
}

代码示例来源：origin: com.github.sgroschupf/zkclient

public boolean delete(final String path) {
  try {
    retryUntilConnected(new Callable<Object>() {
      @Override
      public Object call() throws Exception {
        _connection.delete(path);
        return null;
      }
    });
    return true;
  } catch (ZkNoNodeException e) {
    return false;
  }
}

代码示例来源：origin: com.101tec/zkclient

/**
 * Add authentication information to the connection. This will be used to identify the user and check access to
 * nodes protected by ACLs
 * 
 * @param scheme
 * @param auth
 */
public void addAuthInfo(final String scheme, final byte[] auth) {
  retryUntilConnected(new Callable<Object>() {
    @Override
    public Object call() throws Exception {
      _connection.addAuthInfo(scheme, auth);
      return null;
    }
  });
}

代码示例来源：origin: com.101tec/zkclient

public List<OpResult> multi(final Iterable<Op> ops) throws ZkException {
    if (ops == null) {
      throw new NullPointerException("ops must not be null.");
    }

    return retryUntilConnected(new Callable<List<OpResult>>() {

      @Override
      public List<OpResult> call() throws Exception {
        return _connection.multi(ops);
      }
    });
  }
}

代码示例来源：origin: com.github.sgroschupf/zkclient

/**
 * Installs a child watch for the given path.
 * 
 * @param path
 * @return the current children of the path or null if the zk node with the given path doesn't exist.
 */
public List<String> watchForChilds(final String path) {
  if (_zookeeperEventThread != null && Thread.currentThread() == _zookeeperEventThread) {
    throw new IllegalArgumentException("Must not be done in the zookeeper event thread.");
  }
  return retryUntilConnected(new Callable<List<String>>() {
    @Override
    public List<String> call() throws Exception {
      exists(path, true);
      try {
        return getChildren(path, true);
      } catch (ZkNoNodeException e) {
        // ignore, the "exists" watch will listen for the parent node to appear
      }
      return null;
    }
  });
}

代码示例来源：origin: com.101tec/zkclient

@SuppressWarnings("unchecked")
protected <T extends Object> T readData(final String path, final Stat stat, final boolean watch) {
  byte[] data = retryUntilConnected(new Callable<byte[]>() {
    @Override
    public byte[] call() throws Exception {
      return _connection.readData(path, stat, watch);
    }
  });
  return (T) derializable(data);
}

代码示例来源：origin: com.101tec/zkclient

/**
 * Installs a child watch for the given path.
 * 
 * @param path
 * @return the current children of the path or null if the zk node with the given path doesn't exist.
 */
public List<String> watchForChilds(final String path) {
  if (_zookeeperEventThread != null && Thread.currentThread() == _zookeeperEventThread) {
    throw new IllegalArgumentException("Must not be done in the zookeeper event thread.");
  }
  return retryUntilConnected(new Callable<List<String>>() {
    @Override
    public List<String> call() throws Exception {
      exists(path, true);
      try {
        return getChildren(path, true);
      } catch (ZkNoNodeException e) {
        // ignore, the "exists" watch will listen for the parent node to appear
      }
      return null;
    }
  });
}

代码示例来源：origin: com.101tec/zkclient

public Stat writeDataReturnStat(final String path, Object datat, final int expectedVersion) {
  final byte[] data = serialize(datat);
  return (Stat) retryUntilConnected(new Callable<Object>() {
    @Override
    public Object call() throws Exception {
      Stat stat = _connection.writeDataReturnStat(path, data, expectedVersion);
      return stat;
    }
  });
}

代码示例来源：origin: com.github.sgroschupf/zkclient

public void writeData(final String path, Object datat, final int expectedVersion) {
  final byte[] data = serialize(datat);
  retryUntilConnected(new Callable<Object>() {
    @Override
    public Object call() throws Exception {
      _connection.writeData(path, data, expectedVersion);
      return null;
    }
  });
}

代码示例来源：origin: com.github.sgroschupf/zkclient

@SuppressWarnings("unchecked")
protected <T extends Object> T readData(final String path, final Stat stat, final boolean watch) {
  byte[] data = retryUntilConnected(new Callable<byte[]>() {
    @Override
    public byte[] call() throws Exception {
      return _connection.readData(path, stat, watch);
    }
  });
  return (T) derializable(data);
}

代码示例来源：origin: com.101tec/zkclient

/**
 * Gets the acl on path
 *
 * @param path
 * @return an entry instance with key = list of acls on node and value = stats.
 * @throws ZkException
 *             if any ZooKeeper exception occurred
 * @throws RuntimeException
 *             if any other exception occurs
 */
public Map.Entry<List<ACL>, Stat> getAcl(final String path) throws ZkException {
  if (path == null) {
    throw new NullPointerException("Missing value for path");
  }
  if (!exists(path)) {
    throw new RuntimeException("trying to get acls on non existing node " + path);
  }
  return retryUntilConnected(new Callable<Map.Entry<List<ACL>, Stat>>() {
    @Override
    public Map.Entry<List<ACL>, Stat> call() throws Exception {
      return _connection.getAcl(path);
    }
  });
}

代码示例来源：origin: com.github.sgroschupf/zkclient

/**
 * Create a node.
 * 
 * @param path
 * @param data
 * @param mode
 * @return create node's path
 * @throws ZkInterruptedException
 *             if operation was interrupted, or a required reconnection got interrupted
 * @throws IllegalArgumentException
 *             if called from anything except the ZooKeeper event thread
 * @throws ZkException
 *             if any ZooKeeper exception occurred
 * @throws RuntimeException
 *             if any other exception occurs
 */
public String create(final String path, Object data, final CreateMode mode) throws ZkInterruptedException, IllegalArgumentException, ZkException, RuntimeException {
  if (path == null) {
    throw new NullPointerException("path must not be null.");
  }
  final byte[] bytes = data == null ? null : serialize(data);
  return retryUntilConnected(new Callable<String>() {
    @Override
    public String call() throws Exception {
      return _connection.create(path, bytes, mode);
    }
  });
}

代码示例来源：origin: com.101tec/zkclient

return retryUntilConnected(new Callable<String>() {
  @Override
  public String call() throws Exception {

代码示例来源：origin: com.101tec/zkclient

retryUntilConnected(new Callable<Void>() {
  @Override
  public Void call() throws Exception {