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

Node.isClosed介绍

[英]Returns true if the node is closed.
[中]如果节点已关闭，则返回true。

代码示例

代码示例来源：origin: apache/flink

@Override
  public void cleanup() {
    if (node != null && !node.isClosed()) {
      node.close();
      node = null;
    }
  }
}

代码示例来源：origin: thinkaurelius/titan

@Override
public void close() throws BackendException {
  if (node != null && !node.isClosed()) {
    node.close();
  }
  client.close();
}

代码示例来源：origin: Netflix/conductor

@Override
  public synchronized void stop() throws Exception {
    if (instance != null && !instance.isClosed()) {
      String port = getPort();
      logger.info("Stopping Elastic Search");
      instance.close();
      instance = null;
      logger.info("Elastic Search on port {} stopped", port);
    }
  }
}

代码示例来源：origin: brianfrankcooper/YCSB

@Override
public void cleanup() throws DBException {
 if (!remoteMode) {
  if (!node.isClosed()) {
   client.close();
   node.close();
  }
 } else {
  client.close();
 }
}

代码示例来源：origin: larsga/Duke

@Override
public void close() {
  if (this.client != null) {
    this.client.close();
    this.client = null;
  }
  if (this.node != null && !this.node.isClosed()) {
    this.node.close();
    this.node = null;
  }
}

代码示例来源：origin: jboss-fuse/fabric8

@Override
  public boolean isClosed() {
    return nodeDelegate.isClosed();
  }
}

代码示例来源：origin: io.fabric8.insight/insight-elasticsearch-factory

@Override
  public boolean isClosed() {
    return nodeDelegate.isClosed();
  }
}

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

public static Injector injector() {
  if ((instance.node != null) && (!instance.node.isClosed()))
    return instance.node.injector();
  return null;
}

代码示例来源：origin: io.fabric8.insight/insight-elasticsearch-factory

@Deactivate
protected void deactivate() {
  if (nodeDelegate != null && !nodeDelegate.isClosed()) {
    nodeDelegate.close();
  }
}

代码示例来源：origin: com.github.dcshock/forklift-replay

@Override
  public void run() {
    if (node != null && !node.isClosed())
      node.close();
  }
});

代码示例来源：origin: dropwizard/dropwizard-elasticsearch

private void closeNode() {
  if (null != node && !node.isClosed()) {
    node.close();
  }
}

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

@Override
public void close() throws IOException {
  if (node != null) {
    log.info("Closing embedded (in JVM) Elasticsearch");
    node.close();
    log.info("Node closed: " + node.isClosed());
  }
  node = null;
}

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

public static Client client() {
  if ((instance.node != null) && (!instance.node.isClosed()))
    return instance.node.client();
  return null;
}

代码示例来源：origin: com.github.tlrx/elasticsearch-test

public void afterClass(Object testClass, Map<String, Object> context) throws Exception {
  for (Object obj : context.values()) {
    if (obj instanceof Node) {
      Node node = (Node) obj;
      if (!node.isClosed()) {
        node.close();
      }
    }
  }
  FileSystemUtils.deleteRecursively(new File(ES_HOME));
}

代码示例来源：origin: tlrx/elasticsearch-test

public void afterClass(Object testClass, Map<String, Object> context) throws Exception {
  for (Object obj : context.values()) {
    if (obj instanceof Node) {
      Node node = (Node) obj;
      if (!node.isClosed()) {
        node.close();
      }
    }
  }
  FileSystemUtils.deleteRecursively(new File(ES_HOME));
}

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

private synchronized void publishNode(NodeAndClient nodeAndClient) {
  assert !nodeAndClient.node().isClosed();
  nodes.put(nodeAndClient.name, nodeAndClient);
  applyDisruptionSchemeToNode(nodeAndClient);
}

代码示例来源：origin: org.hawkular.titan/titan-es

@Override
public void close() throws BackendException {
  client.close();
  if (node != null && !node.isClosed()) {
    node.close();
  }
}

代码示例来源：origin: com.thinkaurelius.titan/titan-es-jre6

@Override
public void close() throws StorageException {
  client.close();
  if (node != null && !node.isClosed()) {
    node.close();
  }
}

代码示例来源：origin: com.github.tlrx/elasticsearch-test

@Override
public void close() {
  if (client() != null) {
    client.close();
  }
  if ((node != null) && (!node.isClosed())) {
    node.close();
    FileSystemUtils.deleteRecursively(new File("./target/elasticsearch-test/"), true);
  }
}

代码示例来源：origin: tlrx/elasticsearch-test

@Override
public void close() {
  if (client() != null) {
    client.close();
  }
  if ((node != null) && (!node.isClosed())) {
    node.close();
    FileSystemUtils.deleteRecursively(new File("./target/elasticsearch-test/"), true);
  }
}