You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2015/12/06 21:17:41 UTC
[2/5] camel git commit: Fixed CS
Fixed CS
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/faf3eb7f
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/faf3eb7f
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/faf3eb7f
Branch: refs/heads/master
Commit: faf3eb7f2db30a3cd9f77ccc29586ee0164e7095
Parents: 7d86043
Author: Andrea Cosentino <an...@gmail.com>
Authored: Sun Dec 6 09:46:05 2015 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Sun Dec 6 18:48:18 2015 +0100
----------------------------------------------------------------------
.../camel/component/elasticsearch/ElasticsearchComponent.java | 2 +-
.../camel/component/elasticsearch/ElasticsearchEndpoint.java | 3 ++-
2 files changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/faf3eb7f/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchComponent.java
----------------------------------------------------------------------
diff --git a/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchComponent.java b/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchComponent.java
index 1a2187f..5249270 100644
--- a/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchComponent.java
+++ b/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchComponent.java
@@ -84,7 +84,7 @@ public class ElasticsearchComponent extends UriEndpointComponent {
throw new IllegalArgumentException();
}
Integer port = split.length > 1 ? Integer.parseInt(split[1]) : ElasticsearchConstants.DEFAULT_PORT;
- addressesTrAd.add(new InetSocketTransportAddress(InetAddress.getByName(hostname), port));
+ addressesTrAd.add(new InetSocketTransportAddress(InetAddress.getByName(hostname), port));
}
return addressesTrAd;
}
http://git-wip-us.apache.org/repos/asf/camel/blob/faf3eb7f/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchEndpoint.java b/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchEndpoint.java
index 114a03b..ed12e40 100644
--- a/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchEndpoint.java
+++ b/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchEndpoint.java
@@ -83,7 +83,8 @@ public class ElasticsearchEndpoint extends DefaultEndpoint {
LOG.info("Joining ElasticSearch cluster " + configuration.getClusterName());
}
if (configuration.getIp() != null) {
- this.client = TransportClient.builder().settings(getSettings()).build().addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(configuration.getIp()), configuration.getPort()));
+ this.client = TransportClient.builder().settings(getSettings()).build()
+ .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(configuration.getIp()), configuration.getPort()));
} else if (configuration.getTransportAddressesList() != null
&& !configuration.getTransportAddressesList().isEmpty()) {
List<TransportAddress> addresses = new ArrayList(configuration.getTransportAddressesList().size());