Elasticsearch component docs
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/746e4263 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/746e4263 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/746e4263 Branch: refs/heads/master Commit: 746e4263438f9094add5c4328960074dd773ed4f Parents: e085ef2 Author: Andrea Cosentino <anco...@gmail.com> Authored: Tue May 12 23:14:11 2015 +0200 Committer: Andrea Cosentino <anco...@gmail.com> Committed: Tue May 12 23:14:11 2015 +0200 ---------------------------------------------------------------------- .../ElasticsearchConfiguration.java | 65 +++++++++++++++----- 1 file changed, 48 insertions(+), 17 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/746e4263/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchConfiguration.java ---------------------------------------------------------------------- diff --git a/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchConfiguration.java b/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchConfiguration.java index 3888ed2..b71b925 100644 --- a/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchConfiguration.java +++ b/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchConfiguration.java @@ -61,23 +61,10 @@ public class ElasticsearchConfiguration { private String transportAddresses; @UriParam(defaultValue = "9300") private int port = ElasticsearchConstants.DEFAULT_PORT; - - public boolean isLocal() { - return local; - } - - public void setLocal(boolean local) { - this.local = local; - } - - public List<InetSocketTransportAddress> getTransportAddressesList() { - return transportAddressesList; - } - - public void setTransportAddressesList(List<InetSocketTransportAddress> transportAddressesList) { - this.transportAddressesList = transportAddressesList; - } + /** + * Name of cluster or use local for local mode + */ public String getClusterName() { return clusterName; } @@ -86,6 +73,9 @@ public class ElasticsearchConfiguration { this.clusterName = clusterName; } + /** + * What operation to perform + */ public String getOperation() { return operation; } @@ -94,6 +84,9 @@ public class ElasticsearchConfiguration { this.operation = operation; } + /** + * The name of the index to act against + */ public String getIndexName() { return indexName; } @@ -102,6 +95,9 @@ public class ElasticsearchConfiguration { this.indexName = indexName; } + /** + * The type of the index to act against + */ public String getIndexType() { return indexType; } @@ -110,6 +106,9 @@ public class ElasticsearchConfiguration { this.indexType = indexType; } + /** + * The write consistency level to use with INDEX and BULK operations (can be any of ONE, QUORUM, ALL or DEFAULT) + */ public WriteConsistencyLevel getConsistencyLevel() { return consistencyLevel; } @@ -118,6 +117,9 @@ public class ElasticsearchConfiguration { this.consistencyLevel = consistencyLevel; } + /** + * The replication type to use with INDEX and BULK operations (can be any of SYNC, ASYNC or DEFAULT) + */ public ReplicationType getReplicationType() { return replicationType; } @@ -125,7 +127,10 @@ public class ElasticsearchConfiguration { public void setReplicationType(ReplicationType replicationType) { this.replicationType = replicationType; } - + + /** + * Is the node going to be allowed to allocate data (shards) to it or not. This setting map to the <tt>node.data</tt> setting. + */ public Boolean getData() { return data; } @@ -134,6 +139,9 @@ public class ElasticsearchConfiguration { this.data = data; } + /** + * The TransportClient remote host ip to use + */ public String getIp() { return ip; } @@ -142,6 +150,10 @@ public class ElasticsearchConfiguration { this.ip = ip; } + /** + * Comma separated list with ip:port formatted remote transport addresses to use. + * The ip and port options must be left blank for transportAddresses to be considered instead. + */ public String getTransportAddresses() { return transportAddresses; } @@ -150,6 +162,9 @@ public class ElasticsearchConfiguration { this.transportAddresses = transportAddresses; } + /** + * The TransportClient remote port to use (defaults to 9300) + */ public int getPort() { return port; } @@ -157,4 +172,20 @@ public class ElasticsearchConfiguration { public void setPort(int port) { this.port = port; } + + public boolean isLocal() { + return local; + } + + public void setLocal(boolean local) { + this.local = local; + } + + public List<InetSocketTransportAddress> getTransportAddressesList() { + return transportAddressesList; + } + + public void setTransportAddressesList(List<InetSocketTransportAddress> transportAddressesList) { + this.transportAddressesList = transportAddressesList; + } } \ No newline at end of file