Page History

...

Maven users will need to add the following dependency to their pom.xml for this component:

<dependency>

<dependency>
    <groupId>org

...

.apache.camel</groupId>

...

    <artifactId>camel-cassandraql</artifactId>

...

    <version>x.y.z</version>

...

    <!-- use the same version as your Camel core version -->

...

</dependency>

URI format

The endpoint can initiate the Cassandra connection or use an existing one.

...

The NamedCassandraIdempotentRepository stores messages keys in a Cassandra table like this:

CREATE TABLE CAMEL_IDEMPOTENT (

...

  NAME varchar,   -- Repository name

...

  KEY varchar,

...

    -- Message key

...

  PRIMARY KEY (NAME, KEY)

...

);

The CassandraIdempotentRepository can be extended to use a different data model.

...

The name NamedCassandraAggregationRepository stores messages by correlation key in a Cassandra table like this:

CREATE TABLE CAMEL_AGGREGATION (

...

  NAME varchar,        -- Repository name

...

  KEY varchar,

...

         -- Correlation id

...

  EXCHANGE_ID varchar, -- Exchange id

...

  EXCHANGE blob,       -- Serialized exchange

...

  PRIMARY KEY (NAME, KEY)

...

);

The CassandraAggregationRepository can be extended to use a different data model.