Cassandra CQL

Cassandra CQL

Scheme: cql

Cassandra 2 CQL3 endpoint

Name Kind Type Required Deprecated Default Value Enum Values Description
beanRef path java.lang.String false beanRef is defined using bean:id
hosts path java.lang.String false Hostname(s) cassansdra server(s). Multiple hosts can be separated by comma.
port path java.lang.Integer false Port number of cassansdra server(s)
keyspace path java.lang.String false Keyspace to use
cql parameter java.lang.String false CQL query to perform. Can be overridden with the message header with key CamelCqlQuery.
prepareStatements parameter boolean false true Whether to use PreparedStatements or regular Statements
clusterName parameter java.lang.String false Cluster name
username parameter java.lang.String false Username for session authentication
password parameter java.lang.String false Password for session authentication
cluster parameter com.datastax.driver.core.Cluster false To use the Cluster instance (you would normally not use this option)
session parameter com.datastax.driver.core.Session false To use the Session instance (you would normally not use this option)
consistencyLevel parameter com.datastax.driver.core.ConsistencyLevel false ANY
ONE
TWO
THREE
QUORUM
ALL
LOCAL_QUORUM
EACH_QUORUM
SERIAL
LOCAL_SERIAL
LOCAL_ONE
Consistency level to use
loadBalancingPolicy parameter java.lang.String false To use a specific LoadBalancingPolicy
resultSetConversionStrategy parameter org.apache.camel.component.cassandra.ResultSetConversionStrategy false How many rows should be retrieved in message body
exchangePattern parameter org.apache.camel.ExchangePattern false InOnly InOnly
RobustInOnly
InOut
InOptionalOut
OutOnly
RobustOutOnly
OutIn
OutOptionalIn
Sets the default exchange pattern when creating an exchange
synchronous parameter boolean false false Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported).

cql consumer

Cassandra 2 CQL3 consumer.