tree: 0526d5e809b884ddd17f656a25044bd31604248b [path history] [tgz]
  1. ReadMe.md
  2. pom.xml
  3. src/
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