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

ZenPing.ping介绍

暂无

代码示例

代码示例来源：origin: org.elasticsearch/elasticsearch

private ZenPing.PingCollection pingAndWait(TimeValue timeout) {
  final CompletableFuture<ZenPing.PingCollection> response = new CompletableFuture<>();
  try {
    zenPing.ping(response::complete, timeout);
  } catch (Exception ex) {
    // logged later
    response.completeExceptionally(ex);
  }
  try {
    return response.get();
  } catch (InterruptedException e) {
    logger.trace("pingAndWait interrupted");
    return new ZenPing.PingCollection();
  } catch (ExecutionException e) {
    logger.warn("Ping execution failed", e);
    return new ZenPing.PingCollection();
  }
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

private ZenPing.PingCollection pingAndWait(TimeValue timeout) {
  final CompletableFuture<ZenPing.PingCollection> response = new CompletableFuture<>();
  try {
    zenPing.ping(response::complete, timeout);
  } catch (Exception ex) {
    // logged later
    response.completeExceptionally(ex);
  }
  try {
    return response.get();
  } catch (InterruptedException e) {
    logger.trace("pingAndWait interrupted");
    return new ZenPing.PingCollection();
  } catch (ExecutionException e) {
    logger.warn("Ping execution failed", e);
    return new ZenPing.PingCollection();
  }
}

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

private ZenPing.PingCollection pingAndWait(TimeValue timeout) {
  final CompletableFuture<ZenPing.PingCollection> response = new CompletableFuture<>();
  try {
    zenPing.ping(response::complete, timeout);
  } catch (Exception ex) {
    // logged later
    response.completeExceptionally(ex);
  }
  try {
    return response.get();
  } catch (InterruptedException e) {
    logger.trace("pingAndWait interrupted");
    return new ZenPing.PingCollection();
  } catch (ExecutionException e) {
    logger.warn("Ping execution failed", e);
    return new ZenPing.PingCollection();
  }
}

代码示例来源：origin: apache/servicemix-bundles

private ZenPing.PingCollection pingAndWait(TimeValue timeout) {
  final CompletableFuture<ZenPing.PingCollection> response = new CompletableFuture<>();
  try {
    zenPing.ping(response::complete, timeout);
  } catch (Exception ex) {
    // logged later
    response.completeExceptionally(ex);
  }
  try {
    return response.get();
  } catch (InterruptedException e) {
    logger.trace("pingAndWait interrupted");
    return new ZenPing.PingCollection();
  } catch (ExecutionException e) {
    logger.warn("Ping execution failed", e);
    return new ZenPing.PingCollection();
  }
}