tree: 665066b84afcf0346ef15fbbbf8e4271d6b093b0 [path history] [tgz]
  1. src/
  2. pom.xml
  3. ReadMe.md
components/camel-cassandraql/ReadMe.md

Camel Cassandra Component

This component aims at integrating Cassandra 2.0+ using the CQL3 API (not the Thrift API). It's based on Cassandra Java Driver provided by DataStax.

URI

Examples

URIDescription
cql:localhost/keyspacesingle host, default port, usual for testing
cql:host1,host2/keyspacemulti host, default port
cql:host1:host2:9042/keyspace
cql:host1:host2default port and keyspace
cql:bean:sessionRefprovided Session reference
cql:bean:clusterRef/keyspaceprovided Cluster reference

Options

OptionDescription
clusterNamecluster name
username and passwordsession authentication
cqlCQL query
consistencyLevelANY, ONE, TWO, QUORUM, LOCAL_QUORUM...
resultSetConversionStrategyhow is ResultSet converted transformed into message body ALL, ONE, LIMIT_10, LIMIT_100...

Message

Incoming

Headers:

  • CamelCqlQuery (optional, String): CQL query

Body

  • (Object[] or Collection<Object>): CQL query parameters to be bound

Outgoing

Body

  • List<Row> if resultSetConversionStrategy is ALL or LIMIT_10
  • Row if resultSetConversionStrategy is ONE