gpt4 book ai didi

org.elasticsearch.discovery.zen.ZenPing.ping()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-19 20:33:31 27 4
gpt4 key购买 nike

本文整理了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();
  }
}

27 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com