camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acosent...@apache.org
Subject [3/3] camel git commit: Elasticsearch component docs
Date Tue, 12 May 2015 21:15:25 GMT
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 <ancosen@gmail.com>
Authored: Tue May 12 23:14:11 2015 +0200
Committer: Andrea Cosentino <ancosen@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


Mime
View raw message