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

TransportService.isLocalNode介绍

暂无

代码示例

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

/**
 * Establishes and returns a new connection to the given node. The connection is NOT maintained by this service, it's the callers
 * responsibility to close the connection once it goes out of scope.
 * @param node the node to connect to
 * @param connectionProfile the connection profile to use
 */
public Transport.Connection openConnection(final DiscoveryNode node, ConnectionProfile connectionProfile) throws IOException {
  if (isLocalNode(node)) {
    return localNodeConnection;
  } else {
    return connectionManager.openConnection(node, connectionProfile);
  }
}

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

/**
 * Returns <code>true</code> iff the given node is already connected.
 */
public boolean nodeConnected(DiscoveryNode node) {
  return isLocalNode(node) || connectionManager.nodeConnected(node);
}

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

/**
 * Returns either a real transport connection or a local node connection if we are using the local node optimization.
 * @throws NodeNotConnectedException if the given node is not connected
 */
public Transport.Connection getConnection(DiscoveryNode node) {
  if (isLocalNode(node)) {
    return localNodeConnection;
  } else {
    return connectionManager.getConnection(node);
  }
}

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

public void disconnectFromNode(DiscoveryNode node) {
  if (isLocalNode(node)) {
    return;
  }
  connectionManager.disconnectFromNode(node);
}

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

/**
 * Connect to the specified node with the given connection profile
 *
 * @param node the node to connect to
 * @param connectionProfile the connection profile to use when connecting to this node
 */
public void connectToNode(final DiscoveryNode node, ConnectionProfile connectionProfile) {
  if (isLocalNode(node)) {
    return;
  }
  connectionManager.connectToNode(node, connectionProfile, connectionValidator(node));
}

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

/**
 * Returns <code>true</code> iff the given node is already connected.
 */
public boolean nodeConnected(DiscoveryNode node) {
  return isLocalNode(node) || connectionManager.nodeConnected(node);
}

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

/**
 * Returns either a real transport connection or a local node connection if we are using the local node optimization.
 * @throws NodeNotConnectedException if the given node is not connected
 */
public Transport.Connection getConnection(DiscoveryNode node) {
  if (isLocalNode(node)) {
    return localNodeConnection;
  } else {
    return connectionManager.getConnection(node);
  }
}

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

/**
 * Returns <code>true</code> iff the given node is already connected.
 */
public boolean nodeConnected(DiscoveryNode node) {
  return isLocalNode(node) || transport.nodeConnected(node);
}

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

public void disconnectFromNode(DiscoveryNode node) {
  if (isLocalNode(node)) {
    return;
  }
  transport.disconnectFromNode(node);
}

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

/**
 * Returns either a real transport connection or a local node connection if we are using the local node optimization.
 * @throws NodeNotConnectedException if the given node is not connected
 */
public Transport.Connection getConnection(DiscoveryNode node) {
  if (isLocalNode(node)) {
    return localNodeConnection;
  } else {
    return transport.getConnection(node);
  }
}

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

public void disconnectFromNode(DiscoveryNode node) {
  if (isLocalNode(node)) {
    return;
  }
  connectionManager.disconnectFromNode(node);
}

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

/**
 * Establishes and returns a new connection to the given node. The connection is NOT maintained by this service, it's the callers
 * responsibility to close the connection once it goes out of scope.
 * @param node the node to connect to
 * @param profile the connection profile to use
 */
public Transport.Connection openConnection(final DiscoveryNode node, ConnectionProfile profile) throws IOException {
  if (isLocalNode(node)) {
    return localNodeConnection;
  } else {
    return transport.openConnection(node, profile);
  }
}

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

/**
 * Establishes and returns a new connection to the given node. The connection is NOT maintained by this service, it's the callers
 * responsibility to close the connection once it goes out of scope.
 * @param node the node to connect to
 * @param connectionProfile the connection profile to use
 */
public Transport.Connection openConnection(final DiscoveryNode node, ConnectionProfile connectionProfile) throws IOException {
  if (isLocalNode(node)) {
    return localNodeConnection;
  } else {
    return connectionManager.openConnection(node, connectionProfile);
  }
}

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

/**
 * Establishes and returns a new connection to the given node. The connection is NOT maintained by this service, it's the callers
 * responsibility to close the connection once it goes out of scope.
 * @param node the node to connect to
 * @param profile the connection profile to use
 */
public Transport.Connection openConnection(final DiscoveryNode node, ConnectionProfile profile) throws IOException {
  if (isLocalNode(node)) {
    return localNodeConnection;
  } else {
    return transport.openConnection(node, profile);
  }
}

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

/**
 * Connect to the specified node with the given connection profile
 *
 * @param node the node to connect to
 * @param connectionProfile the connection profile to use when connecting to this node
 */
public void connectToNode(final DiscoveryNode node, ConnectionProfile connectionProfile) {
  if (isLocalNode(node)) {
    return;
  }
  connectionManager.connectToNode(node, connectionProfile, connectionValidator(node));
}

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

/**
 * Connect to the specified node with the given connection profile
 *
 * @param node the node to connect to
 * @param connectionProfile the connection profile to use when connecting to this node
 */
public void connectToNode(final DiscoveryNode node, ConnectionProfile connectionProfile) {
  if (isLocalNode(node)) {
    return;
  }
  transport.connectToNode(node, connectionProfile, (newConnection, actualProfile) -> {
    // We don't validate cluster names to allow for tribe node connections.
    final DiscoveryNode remote = handshake(newConnection, actualProfile.getHandshakeTimeout().millis(), cn -> true);
    if (node.equals(remote) == false) {
      throw new ConnectTransportException(node, "handshake failed. unexpected remote node " + remote);
    }
  });
}