Component docs
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/4cc3541b Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/4cc3541b Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/4cc3541b Branch: refs/heads/master Commit: 4cc3541bef457d2b2a6c02f51bda2270a2082047 Parents: 5d66a29 Author: Claus Ibsen <davscl...@apache.org> Authored: Mon May 11 09:31:13 2015 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Mon May 11 09:31:13 2015 +0200 ---------------------------------------------------------------------- .../component/cassandra/CassandraEndpoint.java | 36 ++++++++++++++++++++ 1 file changed, 36 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/4cc3541b/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/CassandraEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/CassandraEndpoint.java b/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/CassandraEndpoint.java index a1d1495..0e28d9f 100644 --- a/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/CassandraEndpoint.java +++ b/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/CassandraEndpoint.java @@ -185,6 +185,9 @@ public class CassandraEndpoint extends DefaultEndpoint { return beanRef; } + /** + * Instead of using a hostname:port, refer to an existing configured Session or Cluster from the Camel registry to be used. + */ public void setBean(String beanRef) { this.beanRef = beanRef; } @@ -203,6 +206,9 @@ public class CassandraEndpoint extends DefaultEndpoint { return hosts; } + /** + * Hostname(s) cassansdra server(s). Multiple hosts can be separated by comma. + */ public void setHosts(String hosts) { this.hosts = hosts; } @@ -211,6 +217,9 @@ public class CassandraEndpoint extends DefaultEndpoint { return port; } + /** + * Port number of cassansdra server(s) + */ public void setPort(Integer port) { this.port = port; } @@ -219,6 +228,9 @@ public class CassandraEndpoint extends DefaultEndpoint { return keyspace; } + /** + * Keyspace to use + */ public void setKeyspace(String keyspace) { this.keyspace = keyspace; } @@ -227,6 +239,9 @@ public class CassandraEndpoint extends DefaultEndpoint { return cql; } + /** + * CQL query to perform. Can be overridden with the message header with key CamelCqlQuery. + */ public void setCql(String cql) { this.cql = cql; } @@ -235,6 +250,9 @@ public class CassandraEndpoint extends DefaultEndpoint { return cluster; } + /** + * To use the Cluster instance (you would normally not use this option) + */ public void setCluster(Cluster cluster) { this.cluster = cluster; } @@ -247,6 +265,9 @@ public class CassandraEndpoint extends DefaultEndpoint { } } + /** + * To use the Session instance (you would normally not use this option) + */ public void setSession(Session session) { this.session = session; } @@ -255,6 +276,9 @@ public class CassandraEndpoint extends DefaultEndpoint { return clusterName; } + /** + * Cluster name + */ public void setClusterName(String clusterName) { this.clusterName = clusterName; } @@ -263,6 +287,9 @@ public class CassandraEndpoint extends DefaultEndpoint { return username; } + /** + * Username for session authentication + */ public void setUsername(String username) { this.username = username; } @@ -271,6 +298,9 @@ public class CassandraEndpoint extends DefaultEndpoint { return password; } + /** + * Password for session authentication + */ public void setPassword(String password) { this.password = password; } @@ -279,6 +309,9 @@ public class CassandraEndpoint extends DefaultEndpoint { return consistencyLevel; } + /** + * Consistency level to use + */ public void setConsistencyLevel(ConsistencyLevel consistencyLevel) { this.consistencyLevel = consistencyLevel; } @@ -287,6 +320,9 @@ public class CassandraEndpoint extends DefaultEndpoint { return resultSetConversionStrategy; } + /** + * To use a custom class that implements logic for converting ResultSet into message body ALL, ONE, LIMIT_10, LIMIT_100... + */ public void setResultSetConversionStrategy(ResultSetConversionStrategy resultSetConversionStrategy) { this.resultSetConversionStrategy = resultSetConversionStrategy; }
