elasticSearch_transport

elasticSearch_transport

	private void initializeClient() throws Exception {
		
		// add transport addresses
		client = new TransportClient(ImmutableSettings.settingsBuilder()
			.put("cluster.name", "elasticsearch") // currently hardcoded
			.put("client.transport.sniff", true));
		
		for (String server : servers) {
			URL indexUrl = new URL(server);
			String host = indexUrl.getHost();
			Integer port = new Integer(indexUrl.getPort());
			index = indexUrl.getPath().substring(1).split("/")[0];
			type = indexUrl.getPath().substring(1).split("/")[1];
			LOG.info("host:" + host);
			LOG.info("port:" + port);
			LOG.info("index:" + index);
			LOG.info("type:" + type);
			client.addTransportAddress(new InetSocketTransportAddress(host, port));				
		}

		int retry = 0;
		while (client.connectedNodes().isEmpty()) {
			retry++;
			LOG.info("waiting for nodes to connect attempt " + retry);
			Thread.sleep(1000);
		}

	}