Spring/spring-boot
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Allow Elasticsearch client-transport-sniff to be configured via the env

Browse Source 
Previously, a TransportClient sniff property could not be configured
while using Spring Boot’s Elasticsearch auto-configuration. This commit
adds a new property, spring.data.elasticsearch.client-transport-sniff,
that can be used to configure the TransportClient while continuing to
use the auto-configuration support.

Closes gh-1838
This commit is contained in:
Andy Wilkinson
2015-03-17 11:48:43 +00:00
parent b82e220008
commit 89b4cac8b0
3 changed files with 16 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/elasticsearch/ElasticsearchAutoConfiguration.java
View File

@@ -87,6 +87,7 @@ public class ElasticsearchAutoConfiguration implements DisposableBean {
TransportClientFactoryBean factory = new TransportClientFactoryBean();
factory.setClusterName(this.properties.getClusterName());
factory.setClusterNodes(this.properties.getClusterNodes());
factory.setClientTransportSniff(this.properties.getClientTransportSniff());
factory.afterPropertiesSet();
TransportClient client = factory.getObject();
this.releasable = client;

14
spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/elasticsearch/ElasticsearchProperties.java
View File

@@ -39,6 +39,11 @@ public class ElasticsearchProperties {
*/
private String clusterNodes;
/**
* Allow the client to sniff for other members of the cluster.
*/
private boolean clientTransportSniff = true;
public String getClusterName() {
return this.clusterName;
}
@@ -54,4 +59,13 @@ public class ElasticsearchProperties {
public void setClusterNodes(String clusterNodes) {
this.clusterNodes = clusterNodes;
}
public boolean getClientTransportSniff() {
return this.clientTransportSniff;
}
public void setClientTransportSniff(boolean clientTransportSniff) {
this.clientTransportSniff = clientTransportSniff;
}
}