List of addTransportAddress() Examples

Examples of addTransportAddress()

org.elasticsearch.client.transport.TransportClient.addTransportAddress()
Adds a transport address that will be used to connect to.
The Node this transport address represents will be used if its possible to connect to it. If it is unavailable, it will be automatically connected to once it is up.
In order to get the list of all the current connected nodes, please see {@link #connectedNodes()}.

Examples of org.elasticsearch.client.transport.TransportClient.addTransportAddress()

    Settings settings = ImmutableSettings.settingsBuilder()
        .put("cluster.name", clusterName).build();


    TransportClient transport = new TransportClient(settings);
    for (InetSocketTransportAddress host : serverAddresses) {
      transport.addTransportAddress(host);
    }
    client = transport;
  }


  private void closeConnection() {

View Full Code Here

Examples of org.elasticsearch.client.transport.TransportClient.addTransportAddress()

    Settings settings = ImmutableSettings.settingsBuilder()
        .put("cluster.name", clusterName).build();


    TransportClient transportClient = new TransportClient(settings);
    for (InetSocketTransportAddress host : serverAddresses) {
      transportClient.addTransportAddress(host);
    }
    if (client != null) {
      client.close();
    }
    client = transportClient;

View Full Code Here

Examples of org.elasticsearch.client.transport.TransportClient.addTransportAddress()

        TransportClient client = new TransportClient();
        for (String esLocation : esLocations) {
            String[] locationSocket = esLocation.split(":");
            String host = locationSocket[0];
            String port = locationSocket.length > 1 ? locationSocket[1] : "9300";
            client.addTransportAddress(new InetSocketTransportAddress(host, Integer.parseInt(port)));
        }
        LOGGER.info("index %s exists?", indexName);
        IndicesExistsRequest existsRequest = client.admin().indices().prepareExists(indexName).request();
        if (client.admin().indices().exists(existsRequest).actionGet().isExists()) {
            LOGGER.info("index %s exists... deleting!", indexName);

View Full Code Here

Examples of org.elasticsearch.client.transport.TransportClient.addTransportAddress()

    Settings settings = ImmutableSettings.settingsBuilder()
        .put("cluster.name", clusterName).build();


    TransportClient transportClient = new TransportClient(settings);
    for (InetSocketTransportAddress host : serverAddresses) {
      transportClient.addTransportAddress(host);
    }
    if (client != null) {
      client.close();
    }
    client = transportClient;

View Full Code Here

Examples of org.elasticsearch.client.transport.TransportClient.addTransportAddress()

    @Override protected Client getClient1() {
        TransportAddress server1Address = ((InternalNode) node("server1")).injector().getInstance(TransportService.class).boundAddress().publishAddress();
        TransportClient client = new TransportClient(settingsBuilder()
                .put("cluster.name", "test-cluster-" + NetworkUtils.getLocalAddress().getHostName())
                .put("discovery.enabled", false).build());
        client.addTransportAddress(server1Address);
        return client;
    }


    @Override protected Client getClient2() {
        TransportAddress server1Address = ((InternalNode) node("server2")).injector().getInstance(TransportService.class).boundAddress().publishAddress();

View Full Code Here

Examples of org.elasticsearch.client.transport.TransportClient.addTransportAddress()

    @Override protected Client getClient2() {
        TransportAddress server1Address = ((InternalNode) node("server2")).injector().getInstance(TransportService.class).boundAddress().publishAddress();
        TransportClient client = new TransportClient(settingsBuilder()
                .put("cluster.name", "test-cluster-" + NetworkUtils.getLocalAddress().getHostName())
                .put("discovery.enabled", false).build());
        client.addTransportAddress(server1Address);
        return client;
    }
}

View Full Code Here

Examples of org.elasticsearch.client.transport.TransportClient.addTransportAddress()

    @Override protected Client getClient1() {
        TransportAddress server1Address = ((InternalNode) node("server1")).injector().getInstance(TransportService.class).boundAddress().publishAddress();
        TransportClient client = new TransportClient(settingsBuilder()
                .put("cluster.name", "test-cluster-" + NetworkUtils.getLocalAddress().getHostName())
                .put("client.transport.sniff", true).build());
        client.addTransportAddress(server1Address);
        return client;
    }


    @Override protected Client getClient2() {
        TransportAddress server2Address = ((InternalNode) node("server2")).injector().getInstance(TransportService.class).boundAddress().publishAddress();

View Full Code Here

Examples of org.elasticsearch.client.transport.TransportClient.addTransportAddress()

    @Override protected Client getClient2() {
        TransportAddress server2Address = ((InternalNode) node("server2")).injector().getInstance(TransportService.class).boundAddress().publishAddress();
        TransportClient client = new TransportClient(settingsBuilder()
                .put("cluster.name", "test-cluster-" + NetworkUtils.getLocalAddress().getHostName())
                .put("client.transport.sniff", true).build());
        client.addTransportAddress(server2Address);
        return client;
    }
}

View Full Code Here

Examples of org.elasticsearch.client.transport.TransportClient.addTransportAddress()

        TransportAddress server1Address = ((InternalNode) node("server1")).injector().getInstance(TransportService.class).boundAddress().publishAddress();
        TransportClient client = new TransportClient(ImmutableSettings
                .settingsBuilder()
                .put("cluster.name", "test-cluster-" + NetworkUtils.getLocalAddress().getHostName())
                .build());
        client.addTransportAddress(server1Address);
        return client;
    }
}

View Full Code Here

Examples of org.elasticsearch.client.transport.TransportClient.addTransportAddress()

    @Override protected Client getClient1() {
        TransportAddress server1Address = ((InternalNode) node("server1")).injector().getInstance(TransportService.class).boundAddress().publishAddress();
        TransportClient client = new TransportClient(settingsBuilder()
                .put("cluster.name", "test-cluster-" + NetworkUtils.getLocalAddress().getHostName())
                .put("client.transport.sniff", false).build());
        client.addTransportAddress(server1Address);
        return client;
    }


    @Override protected Client getClient2() {
        TransportAddress server2Address = ((InternalNode) node("server2")).injector().getInstance(TransportService.class).boundAddress().publishAddress();

View Full Code Here

0 1 2

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.