# How to connect to ElasticSearch via Spring Boot App Startup?

**URL:** <https://discuss.elastic.co/t/how-to-connect-to-elasticsearch-via-spring-boot-app-startup/94255>\
**Category:** Elasticsearch\
**Created:** [July 23, 2017, 7:39pm UTC](https://discuss.elastic.co/t/how-to-connect-to-elasticsearch-via-spring-boot-app-startup/94255 "2017-07-23T19:39:31Z")\
**Posts on this page:** 2\
**Page:** 1

<div class="post-metadata">

**Author:** ![halogeek](https://avatars.discourse-cdn.com/v4/letter/h/c37758/32.png) [@halogeek](https://discuss.elastic.co/u/halogeek)\
**Post date:** [July 23, 2017, 7:39pm UTC](https://discuss.elastic.co/t/how-to-connect-to-elasticsearch-via-spring-boot-app-startup/94255/1 "2017-07-23T19:39:31Z")

</div>

Am using Spring Boot along with ElasticSearch's Java Client  
to connect to a local ElasticSearch 5.5.0 instance by using the  
following code inside:

```
public void (String... args)

```

Here's the current code:

```
@SpringBootApplication
public class Application implements CommandLineRunner {

	Logger log = Logger.getLogger(Application.class);

	public static void main(String args[]) {
		SpringApplication.run(Application.class, args);
	}

	@Override
	public void run(String... args) throws Exception {
		log.info("Inside run() method");
		Settings settings = Settings.builder().put("cluster.name", "app-cluster")
				                              .put("client.transport.sniff", true)
				                              .build();

		TransportClient client = new PreBuiltTransportClient(settings);

		client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));

		// Add documents
		IndexResponse response = client.prepareIndex("test", "tests")
			.setSource(
				jsonBuilder().startObject()
				 			 .field("message", "Hello!")
				 			 .field("Date", new Date())
				 			 .endObject()
			).get();
	}

}

```

My pom.xml:

```
<parent>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-parent</artifactId>
	<version>1.5.4.RELEASE</version>
</parent>

<properties>
	<java.version>1.8</java.version>
</properties>

<repositories>
	<repository>
		<id>spring-releases</id>
		<url>https://repo.spring.io/libs-release</url>
	</repository>
</repositories>

<pluginRepositories>
	<pluginRepository>
		<id>spring-releases</id>
		<url>https://repo.spring.io/libs-release</url>
	</pluginRepository>
</pluginRepositories>

<dependencies>
	<!-- Spring -->
	<dependency>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-web</artifactId>
	</dependency>

	<dependency>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-test</artifactId>
		<scope>test</scope>
	</dependency>

	<!-- Elasticsearch -->
	<dependency>
		<groupId>org.elasticsearch</groupId>
		<artifactId>elasticsearch</artifactId>			
		<version>5.5.0</version>
	</dependency>

	<dependency>
		<groupId>org.elasticsearch.client</groupId>
		<artifactId>transport</artifactId>
		<version>5.5.0</version>
	</dependency>
 </dependencies>

```

Question:

1. Is there an Spring based annotation that I can use to autoload config files and start the connection to the ElasticSearch server in my Spring Boot app? Kind of like a ServletInitializer or ServletFilter?

2. Where (what file in the codebase) would I place this and have my Application load it (connect via settings and client) upon Spring Boot Startup?

3. Also, is there a way to set it up so an external client can call the client.disconnect()?

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [August 20, 2017, 7:39pm UTC](https://discuss.elastic.co/t/how-to-connect-to-elasticsearch-via-spring-boot-app-startup/94255/2 "2017-08-20T19:39:51Z")

</div>

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.