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

TransportService.disconnectFromNode介绍

暂无

代码示例

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

@Override
public void close() {
  synchronized (mutex) {
    if (closed) {
      return;
    }
    closed = true;
    FutureUtils.cancel(nodesSamplerFuture);
    for (DiscoveryNode node : nodes) {
      transportService.disconnectFromNode(node);
    }
    for (DiscoveryNode listedNode : listedNodes) {
      transportService.disconnectFromNode(listedNode);
    }
    nodes = Collections.emptyList();
  }
}

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

/**
 * Disconnects from all nodes except the ones provided as parameter
 */
public void disconnectFromNodesExcept(DiscoveryNodes nodesToKeep) {
  Set<DiscoveryNode> currentNodes = new HashSet<>(nodes.keySet());
  for (DiscoveryNode node : nodesToKeep) {
    currentNodes.remove(node);
  }
  for (final DiscoveryNode node : currentNodes) {
    try (Releasable ignored = nodeLocks.acquire(node)) {
      Integer current = nodes.remove(node);
      assert current != null : "node " + node + " was removed in event but not in internal nodes";
      try {
        transportService.disconnectFromNode(node);
      } catch (Exception e) {
        logger.warn(() -> new ParameterizedMessage("failed to disconnect to node [{}]", node), e);
      }
    }
  }
}

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

public TransportClientNodesService removeTransportAddress(TransportAddress transportAddress) {
  synchronized (mutex) {
    if (closed) {
      throw new IllegalStateException("transport client is closed, can't remove an address");
    }
    List<DiscoveryNode> listNodesBuilder = new ArrayList<>();
    for (DiscoveryNode otherNode : listedNodes) {
      if (!otherNode.getAddress().equals(transportAddress)) {
        listNodesBuilder.add(otherNode);
      } else {
        logger.debug("removing address [{}] from listed nodes", otherNode);
      }
    }
    listedNodes = Collections.unmodifiableList(listNodesBuilder);
    List<DiscoveryNode> nodesBuilder = new ArrayList<>();
    for (DiscoveryNode otherNode : nodes) {
      if (!otherNode.getAddress().equals(transportAddress)) {
        nodesBuilder.add(otherNode);
      } else {
        logger.debug("disconnecting from node with address [{}]", otherNode);
        transportService.disconnectFromNode(otherNode);
      }
    }
    nodes = Collections.unmodifiableList(nodesBuilder);
    nodesSampler.sample();
  }
  return this;
}

代码示例来源：origin: harbby/presto-connectors

public void close() {
  synchronized (mutex) {
    if (closed) {
      return;
    }
    closed = true;
    FutureUtils.cancel(nodesSamplerFuture);
    for (DiscoveryNode node : nodes) {
      transportService.disconnectFromNode(node);
    }
    for (DiscoveryNode listedNode : listedNodes) {
      transportService.disconnectFromNode(listedNode);
    }
    nodes = Collections.emptyList();
  }
}

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

@Override
public void close() {
  synchronized (mutex) {
    if (closed) {
      return;
    }
    closed = true;
    FutureUtils.cancel(nodesSamplerFuture);
    for (DiscoveryNode node : nodes) {
      transportService.disconnectFromNode(node);
    }
    for (DiscoveryNode listedNode : listedNodes) {
      transportService.disconnectFromNode(listedNode);
    }
    nodes = Collections.emptyList();
  }
}

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

@Override
public void close() {
  synchronized (mutex) {
    if (closed) {
      return;
    }
    closed = true;
    FutureUtils.cancel(nodesSamplerFuture);
    for (DiscoveryNode node : nodes) {
      transportService.disconnectFromNode(node);
    }
    for (DiscoveryNode listedNode : listedNodes) {
      transportService.disconnectFromNode(listedNode);
    }
    nodes = Collections.emptyList();
  }
}

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

/**
 * Disconnects from all nodes except the ones provided as parameter
 */
public void disconnectFromNodesExcept(DiscoveryNodes nodesToKeep) {
  Set<DiscoveryNode> currentNodes = new HashSet<>(nodes.keySet());
  for (DiscoveryNode node : nodesToKeep) {
    currentNodes.remove(node);
  }
  for (final DiscoveryNode node : currentNodes) {
    try (Releasable ignored = nodeLocks.acquire(node)) {
      Integer current = nodes.remove(node);
      assert current != null : "node " + node + " was removed in event but not in internal nodes";
      try {
        transportService.disconnectFromNode(node);
      } catch (Exception e) {
        logger.warn(() -> new ParameterizedMessage("failed to disconnect to node [{}]", node), e);
      }
    }
  }
}

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

/**
 * Disconnects from all nodes except the ones provided as parameter
 */
public void disconnectFromNodesExcept(DiscoveryNodes nodesToKeep) {
  Set<DiscoveryNode> currentNodes = new HashSet<>(nodes.keySet());
  for (DiscoveryNode node : nodesToKeep) {
    currentNodes.remove(node);
  }
  for (final DiscoveryNode node : currentNodes) {
    try (Releasable ignored = nodeLocks.acquire(node)) {
      Integer current = nodes.remove(node);
      assert current != null : "node " + node + " was removed in event but not in internal nodes";
      try {
        transportService.disconnectFromNode(node);
      } catch (Exception e) {
        logger.warn(() -> new ParameterizedMessage("failed to disconnect to node [{}]", node), e);
      }
    }
  }
}

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

/**
 * Disconnects from all nodes except the ones provided as parameter
 */
public void disconnectFromNodesExcept(DiscoveryNodes nodesToKeep) {
  Set<DiscoveryNode> currentNodes = new HashSet<>(nodes.keySet());
  for (DiscoveryNode node : nodesToKeep) {
    currentNodes.remove(node);
  }
  for (final DiscoveryNode node : currentNodes) {
    try (Releasable ignored = nodeLocks.acquire(node)) {
      Integer current = nodes.remove(node);
      assert current != null : "node " + node + " was removed in event but not in internal nodes";
      try {
        transportService.disconnectFromNode(node);
      } catch (Exception e) {
        logger.warn((Supplier<?>) () -> new ParameterizedMessage("failed to disconnect to node [{}]", node), e);
      }
    }
  }
}

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

public TransportClientNodesService removeTransportAddress(TransportAddress transportAddress) {
  synchronized (mutex) {
    if (closed) {
      throw new IllegalStateException("transport client is closed, can't remove an address");
    }
    List<DiscoveryNode> listNodesBuilder = new ArrayList<>();
    for (DiscoveryNode otherNode : listedNodes) {
      if (!otherNode.getAddress().equals(transportAddress)) {
        listNodesBuilder.add(otherNode);
      } else {
        logger.debug("removing address [{}] from listed nodes", otherNode);
      }
    }
    listedNodes = Collections.unmodifiableList(listNodesBuilder);
    List<DiscoveryNode> nodesBuilder = new ArrayList<>();
    for (DiscoveryNode otherNode : nodes) {
      if (!otherNode.getAddress().equals(transportAddress)) {
        nodesBuilder.add(otherNode);
      } else {
        logger.debug("disconnecting from node with address [{}]", otherNode);
        transportService.disconnectFromNode(otherNode);
      }
    }
    nodes = Collections.unmodifiableList(nodesBuilder);
    nodesSampler.sample();
  }
  return this;
}

代码示例来源：origin: harbby/presto-connectors

public TransportClientNodesService removeTransportAddress(TransportAddress transportAddress) {
  synchronized (mutex) {
    if (closed) {
      throw new IllegalStateException("transport client is closed, can't remove an address");
    }
    List<DiscoveryNode> listNodesBuilder = new ArrayList<>();
    for (DiscoveryNode otherNode : listedNodes) {
      if (!otherNode.getAddress().equals(transportAddress)) {
        listNodesBuilder.add(otherNode);
      } else {
        logger.debug("removing address [{}] from listed nodes", otherNode);
      }
    }
    listedNodes = Collections.unmodifiableList(listNodesBuilder);
    List<DiscoveryNode> nodesBuilder = new ArrayList<>();
    for (DiscoveryNode otherNode : nodes) {
      if (!otherNode.getAddress().equals(transportAddress)) {
        nodesBuilder.add(otherNode);
      } else {
        logger.debug("disconnecting from node with address [{}]", otherNode);
        transportService.disconnectFromNode(otherNode);
      }
    }
    nodes = Collections.unmodifiableList(nodesBuilder);
    nodesSampler.sample();
  }
  return this;
}

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

public TransportClientNodesService removeTransportAddress(TransportAddress transportAddress) {
  synchronized (mutex) {
    if (closed) {
      throw new IllegalStateException("transport client is closed, can't remove an address");
    }
    List<DiscoveryNode> listNodesBuilder = new ArrayList<>();
    for (DiscoveryNode otherNode : listedNodes) {
      if (!otherNode.getAddress().equals(transportAddress)) {
        listNodesBuilder.add(otherNode);
      } else {
        logger.debug("removing address [{}] from listed nodes", otherNode);
      }
    }
    listedNodes = Collections.unmodifiableList(listNodesBuilder);
    List<DiscoveryNode> nodesBuilder = new ArrayList<>();
    for (DiscoveryNode otherNode : nodes) {
      if (!otherNode.getAddress().equals(transportAddress)) {
        nodesBuilder.add(otherNode);
      } else {
        logger.debug("disconnecting from node with address [{}]", otherNode);
        transportService.disconnectFromNode(otherNode);
      }
    }
    nodes = Collections.unmodifiableList(nodesBuilder);
    nodesSampler.sample();
  }
  return this;
}

代码示例来源：origin: harbby/presto-connectors

transportService.disconnectFromNode(node);
} catch (Throwable e) {
  logger.warn("failed to disconnect to node [" + node + "]", e);

代码示例来源：origin: harbby/presto-connectors

transportService.disconnectFromNode(listedNode);
hostFailureListener.onNodeDisconnected(listedNode, e);

代码示例来源：origin: harbby/presto-connectors

} catch (Throwable e) {
  logger.info("failed to get local cluster state info for {}, disconnecting...", e, listedNode);
  transportService.disconnectFromNode(listedNode);
  latch.countDown();
  hostFailureListener.onNodeDisconnected(listedNode, e);