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

TransportService.addConnectionListener介绍

暂无

代码示例

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

public FaultDetection(Settings settings, ThreadPool threadPool, TransportService transportService, ClusterName clusterName) {
  this.threadPool = threadPool;
  this.transportService = transportService;
  this.clusterName = clusterName;
  this.connectOnNetworkDisconnect = CONNECT_ON_NETWORK_DISCONNECT_SETTING.get(settings);
  this.pingInterval = PING_INTERVAL_SETTING.get(settings);
  this.pingRetryTimeout = PING_TIMEOUT_SETTING.get(settings);
  this.pingRetryCount = PING_RETRIES_SETTING.get(settings);
  this.registerConnectionListener = REGISTER_CONNECTION_LISTENER_SETTING.get(settings);
  this.connectionListener = new FDConnectionListener();
  if (registerConnectionListener) {
    transportService.addConnectionListener(connectionListener);
  }
}

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

public FaultDetection(Settings settings, ThreadPool threadPool, TransportService transportService, ClusterName clusterName) {
  super(settings);
  this.threadPool = threadPool;
  this.transportService = transportService;
  this.clusterName = clusterName;
  this.connectOnNetworkDisconnect = CONNECT_ON_NETWORK_DISCONNECT_SETTING.get(settings);
  this.pingInterval = PING_INTERVAL_SETTING.get(settings);
  this.pingRetryTimeout = PING_TIMEOUT_SETTING.get(settings);
  this.pingRetryCount = PING_RETRIES_SETTING.get(settings);
  this.registerConnectionListener = REGISTER_CONNECTION_LISTENER_SETTING.get(settings);
  this.connectionListener = new FDConnectionListener();
  if (registerConnectionListener) {
    transportService.addConnectionListener(connectionListener);
  }
}

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

public FaultDetection(Settings settings, ThreadPool threadPool, TransportService transportService, ClusterName clusterName) {
  super(settings);
  this.threadPool = threadPool;
  this.transportService = transportService;
  this.clusterName = clusterName;
  this.connectOnNetworkDisconnect = CONNECT_ON_NETWORK_DISCONNECT_SETTING.get(settings);
  this.pingInterval = PING_INTERVAL_SETTING.get(settings);
  this.pingRetryTimeout = PING_TIMEOUT_SETTING.get(settings);
  this.pingRetryCount = PING_RETRIES_SETTING.get(settings);
  this.registerConnectionListener = REGISTER_CONNECTION_LISTENER_SETTING.get(settings);
  this.connectionListener = new FDConnectionListener();
  if (registerConnectionListener) {
    transportService.addConnectionListener(connectionListener);
  }
}

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

public FaultDetection(Settings settings, ThreadPool threadPool, TransportService transportService, ClusterName clusterName) {
  super(settings);
  this.threadPool = threadPool;
  this.transportService = transportService;
  this.clusterName = clusterName;
  this.connectOnNetworkDisconnect = CONNECT_ON_NETWORK_DISCONNECT_SETTING.get(settings);
  this.pingInterval = PING_INTERVAL_SETTING.get(settings);
  this.pingRetryTimeout = PING_TIMEOUT_SETTING.get(settings);
  this.pingRetryCount = PING_RETRIES_SETTING.get(settings);
  this.registerConnectionListener = REGISTER_CONNECTION_LISTENER_SETTING.get(settings);
  this.connectionListener = new FDConnectionListener();
  if (registerConnectionListener) {
    transportService.addConnectionListener(connectionListener);
  }
}

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

public FaultDetection(Settings settings, ThreadPool threadPool, TransportService transportService, ClusterName clusterName) {
  super(settings);
  this.threadPool = threadPool;
  this.transportService = transportService;
  this.clusterName = clusterName;
  this.connectOnNetworkDisconnect = settings.getAsBoolean(SETTING_CONNECT_ON_NETWORK_DISCONNECT, false);
  this.pingInterval = settings.getAsTime(SETTING_PING_INTERVAL, timeValueSeconds(1));
  this.pingRetryTimeout = settings.getAsTime(SETTING_PING_TIMEOUT, timeValueSeconds(30));
  this.pingRetryCount = settings.getAsInt(SETTING_PING_RETRIES, 3);
  this.registerConnectionListener = settings.getAsBoolean(SETTING_REGISTER_CONNECTION_LISTENER, true);
  this.connectionListener = new FDConnectionListener();
  if (registerConnectionListener) {
    transportService.addConnectionListener(connectionListener);
  }
}

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

serviceA.addConnectionListener(waitForConnection);
serviceB.addConnectionListener(waitForConnection);
serviceC.addConnectionListener(waitForConnection);

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

/**
 * Creates a new {@link RemoteClusterConnection}
 * @param settings the nodes settings object
 * @param clusterAlias the configured alias of the cluster to connect to
 * @param seedNodes a list of seed nodes to discover eligible nodes from
 * @param transportService the local nodes transport service
 * @param maxNumRemoteConnections the maximum number of connections to the remote cluster
 * @param nodePredicate a predicate to filter eligible remote nodes to connect to
 */
RemoteClusterConnection(Settings settings, String clusterAlias, List<DiscoveryNode> seedNodes,
            TransportService transportService, int maxNumRemoteConnections, Predicate<DiscoveryNode> nodePredicate) {
  super(settings);
  this.transportService = transportService;
  this.maxNumRemoteConnections = maxNumRemoteConnections;
  this.nodePredicate = nodePredicate;
  this.clusterAlias = clusterAlias;
  ConnectionProfile.Builder builder = new ConnectionProfile.Builder();
  builder.setConnectTimeout(TcpTransport.TCP_CONNECT_TIMEOUT.get(settings));
  builder.setHandshakeTimeout(TcpTransport.TCP_CONNECT_TIMEOUT.get(settings));
  builder.addConnections(6, TransportRequestOptions.Type.REG, TransportRequestOptions.Type.PING); // TODO make this configurable?
  builder.addConnections(0, // we don't want this to be used for anything else but search
    TransportRequestOptions.Type.BULK,
    TransportRequestOptions.Type.STATE,
    TransportRequestOptions.Type.RECOVERY);
  remoteProfile = builder.build();
  connectedNodes = new ConnectedNodes(clusterAlias);
  this.seedNodes = Collections.unmodifiableList(seedNodes);
  this.connectHandler = new ConnectHandler();
  transportService.addConnectionListener(this);
}