Commit 4a7d7dd4 authored by Pedro Eduardo Trujillo's avatar Pedro Eduardo Trujillo
Browse files

Actualiza cliente elastic y añade credenciales

parent 184f93f8
Loading
Loading
Loading
Loading
+7 −3
Original line number Diff line number Diff line
@@ -13,7 +13,7 @@ import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.cluster.node.DiscoveryNode;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.InetSocketTransportAddress;
import org.elasticsearch.transport.client.PreBuiltTransportClient;
import org.elasticsearch.xpack.client.PreBuiltXPackTransportClient;

import es.redmic.exception.common.ExceptionType;
import es.redmic.exception.common.InternalException;
@@ -25,6 +25,7 @@ public class EsClientProvider {
	private List<String> addresses;
	private Integer port;
	private String clusterName;
	private String xpackSecurityUser;
	
	protected static Logger logger = LogManager.getLogger();

@@ -43,9 +44,12 @@ public class EsClientProvider {
	@PostConstruct
	private void connect() {

		Settings settings = Settings.builder().put("cluster.name", this.clusterName).build();
		Settings settings = Settings.builder()
		    .put("cluster.name", this.clusterName)
		    .put("xpack.security.user", this.xpackSecurityUser)
		    .build();

		client = new PreBuiltTransportClient(settings);
		client = new PreBuiltXPackTransportClient(settings);

		for (String address : addresses) {
			try {