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
port path java.lang.Integer false
keyspace path java.lang.String false
cql parameter java.lang.String false
prepareStatements parameter boolean false true Whether to use PreparedStatements or regular Statements
clusterName parameter java.lang.String false
username parameter java.lang.String false
password parameter java.lang.String false
cluster parameter com.datastax.driver.core.Cluster false
session parameter com.datastax.driver.core.Session false
consistencyLevel parameter com.datastax.driver.core.ConsistencyLevel false ANY
ONE
TWO
THREE
QUORUM
ALL
LOCAL_QUORUM
EACH_QUORUM
SERIAL
LOCAL_SERIAL
LOCAL_ONE
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.