Cassandra CQL

Cassandra CQL

Description: Represents the component that manages CassandraEndpoint. This component is based on Datastax Java Driver for Cassandra.
Scheme: cql
Syntax: cql:beanRef:hosts:port/keyspace
Maven: org.apache.camel/camel-cassandraql/2.16.1

Cassandra 2 CQL3 endpoint

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

cql consumer

Cassandra 2 CQL3 consumer.