A C D F G I L M N O P R S T U

A

add(CamelContext, String, Exchange) - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

Insert or update exchange in aggregation table.

add(K) - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

all() - Static method in class org.apache.camel.component.cassandra.ResultSetConversionStrategies

Retrieve all rows.

append(Object[], Object...) - Static method in class org.apache.camel.utils.cassandra.CassandraUtils

Append values to given array.

append(String[], String...) - Static method in class org.apache.camel.utils.cassandra.CassandraUtils

Append values to given array.

applyConsistencyLevel(T, ConsistencyLevel) - Static method in class org.apache.camel.utils.cassandra.CassandraUtils

Apply consistency level if provided, else leave default.

C

CassandraAggregationException - Exception in org.apache.camel.processor.aggregate.cassandra

Error occurred in Cassandra Aggregation repository

CassandraAggregationException(String, Exchange, Throwable) - Constructor for exception org.apache.camel.processor.aggregate.cassandra.CassandraAggregationException

CassandraAggregationRepository - Class in org.apache.camel.processor.aggregate.cassandra

Implementation of AggregationRepository using Cassandra table to store exchanges.

CassandraAggregationRepository() - Constructor for class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

CassandraAggregationRepository(Session) - Constructor for class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

CassandraAggregationRepository(Cluster, String) - Constructor for class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

CassandraCamelCodec - Class in org.apache.camel.processor.aggregate.cassandra

Marshall/unmarshall Exchange to/from a ByteBuffer.

CassandraCamelCodec() - Constructor for class org.apache.camel.processor.aggregate.cassandra.CassandraCamelCodec

CassandraComponent - Class in org.apache.camel.component.cassandra

Represents the component that manages CassandraEndpoint.

CassandraComponent() - Constructor for class org.apache.camel.component.cassandra.CassandraComponent

CassandraConstants - Class in org.apache.camel.component.cassandra

Cassandra QL Endpoint constants

CassandraConsumer - Class in org.apache.camel.component.cassandra

Cassandra 2 CQL3 consumer.

CassandraConsumer(CassandraEndpoint, Processor) - Constructor for class org.apache.camel.component.cassandra.CassandraConsumer

CassandraEndpoint - Class in org.apache.camel.component.cassandra

The cql component aims at integrating Cassandra 2.0+ using the CQL3 API (not the Thrift API).

CassandraEndpoint(String, Component) - Constructor for class org.apache.camel.component.cassandra.CassandraEndpoint

CassandraEndpoint(String, CassandraComponent, Cluster, Session, String) - Constructor for class org.apache.camel.component.cassandra.CassandraEndpoint

CassandraIdempotentRepository<K> - Class in org.apache.camel.processor.idempotent.cassandra

Implementation of IdempotentRepository using Cassandra table to store message ids.

CassandraIdempotentRepository() - Constructor for class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

CassandraIdempotentRepository(Session) - Constructor for class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

CassandraIdempotentRepository(Cluster, String) - Constructor for class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

CassandraLoadBalancingPolicies - Class in org.apache.camel.utils.cassandra

CassandraLoadBalancingPolicies() - Constructor for class org.apache.camel.utils.cassandra.CassandraLoadBalancingPolicies

CassandraProducer - Class in org.apache.camel.component.cassandra

Cassandra 2 CQL3 producer.

CassandraProducer(CassandraEndpoint) - Constructor for class org.apache.camel.component.cassandra.CassandraProducer

CassandraSessionHolder - Class in org.apache.camel.utils.cassandra

Holds a Cassandra Session and manages its lifecycle

CassandraSessionHolder(Cluster, String) - Constructor for class org.apache.camel.utils.cassandra.CassandraSessionHolder

CassandraSessionHolder(Session) - Constructor for class org.apache.camel.utils.cassandra.CassandraSessionHolder

CassandraUtils - Class in org.apache.camel.utils.cassandra

clear() - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

concat(Object[], Object[]) - Static method in class org.apache.camel.utils.cassandra.CassandraUtils

Concatenate 2 arrays.

concat(String[], String[]) - Static method in class org.apache.camel.utils.cassandra.CassandraUtils

Concatenate 2 arrays.

confirm(CamelContext, String) - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

Remove exchange by Id from aggregation table.

confirm(K) - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

contains(K) - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

CQL_QUERY - Static variable in class org.apache.camel.component.cassandra.CassandraConstants

In Message header: CQL Query

createClusterBuilder() - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

createConsumer(Processor) - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

createEndpoint(String, String, Map<String, Object>) - Method in class org.apache.camel.component.cassandra.CassandraComponent

createProducer() - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

D

dcAwareRoundRobinPolicy - Variable in class org.apache.camel.utils.cassandra.CassandraLoadBalancingPolicies

doStart() - Method in class org.apache.camel.component.cassandra.CassandraConsumer

doStart() - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

doStart() - Method in class org.apache.camel.component.cassandra.CassandraProducer

doStart() - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

doStart() - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

doStop() - Method in class org.apache.camel.component.cassandra.CassandraConsumer

doStop() - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

doStop() - Method in class org.apache.camel.component.cassandra.CassandraProducer

doStop() - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

doStop() - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

F

fillMessage(ResultSet, Message) - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

Copy ResultSet into Message.

fromName(String) - Static method in class org.apache.camel.component.cassandra.ResultSetConversionStrategies

Get ResultSetConversionStrategy from String

G

generateDelete(String, String[], boolean) - Static method in class org.apache.camel.utils.cassandra.CassandraUtils

Generate delete where columns = ? CQL.

generateDelete(String, String[], int, boolean) - Static method in class org.apache.camel.utils.cassandra.CassandraUtils

Generate delete where columns = ? CQL.

generateInsert(String, String[], boolean, Integer) - Static method in class org.apache.camel.utils.cassandra.CassandraUtils

Generate Insert CQL.

generateSelect(String, String[], String[]) - Static method in class org.apache.camel.utils.cassandra.CassandraUtils

Generate select where columns = ? CQL.

generateSelect(String, String[], String[], int) - Static method in class org.apache.camel.utils.cassandra.CassandraUtils

Generate select where columns = ? CQL.

generateTruncate(String) - Static method in class org.apache.camel.utils.cassandra.CassandraUtils

Generate delete where columns = ? CQL.

get(CamelContext, String) - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

Get exchange from aggregation table by aggregation key.

getBean() - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

getBeanRef() - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

Deprecated.

getBody(ResultSet) - Method in interface org.apache.camel.component.cassandra.ResultSetConversionStrategy

getCluster() - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

getCluster() - Method in class org.apache.camel.utils.cassandra.CassandraSessionHolder

getClusterName() - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

getConsistencyLevel() - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

getCql() - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

getDeadLetterUri() - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

getEndpoint() - Method in class org.apache.camel.component.cassandra.CassandraConsumer

getEndpoint() - Method in class org.apache.camel.component.cassandra.CassandraProducer

getExchangeColumn() - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

getExchangeIdColumn() - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

getHosts() - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

getKeys() - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

Get aggregation exchangeIds from aggregation table.

getKeyspace() - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

getKeyspace() - Method in class org.apache.camel.utils.cassandra.CassandraSessionHolder

getLoadBalancingPolicy() - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

To use a specific LoadBalancingPolicy

getLoadBalancingPolicy(String) - Method in class org.apache.camel.utils.cassandra.CassandraLoadBalancingPolicies

getMaximumRedeliveries() - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

getName() - Method in class org.apache.camel.processor.aggregate.cassandra.NamedCassandraAggregationRepository

getName() - Method in class org.apache.camel.processor.idempotent.cassandra.NamedCassandraIdempotentRepository

getPassword() - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

getPKColumns() - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

getPKColumns() - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

getPKValues(String) - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

Generate primary key values from aggregation key.

getPKValues(K) - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

getPort() - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

getPrefixPKValues() - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

getPrefixPKValues() - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

getReadConsistencyLevel() - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

getReadConsistencyLevel() - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

getRecoveryIntervalInMillis() - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

getResultSetConversionStrategy() - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

getSession() - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

getSession() - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

getSession() - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

getSession() - Method in class org.apache.camel.utils.cassandra.CassandraSessionHolder

getSessionHolder() - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

getTable() - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

getTable() - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

getTtl() - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

getTtl() - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

getUsername() - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

getWriteConsistencyLevel() - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

getWriteConsistencyLevel() - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

I

initClearStatement() - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

initDeleteStatement() - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

initInsertStatement() - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

initSelectStatement() - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

initSelectStatement() - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

isAllowSerializedHeaders() - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

isApplied(ResultSet) - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

isEmpty(Object[]) - Static method in class org.apache.camel.utils.cassandra.CassandraUtils

Test if the array is null or empty.

isPrepareStatements() - Method in class org.apache.camel.component.cassandra.CassandraConsumer

isPrepareStatements() - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

isPrepareStatements() - Method in class org.apache.camel.component.cassandra.CassandraProducer

isSingleton() - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

isUseRecovery() - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

L

limit(int) - Static method in class org.apache.camel.component.cassandra.ResultSetConversionStrategies

Retrieve a limited list of rows.

M

marshallExchange(CamelContext, Exchange, boolean) - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraCamelCodec

N

NamedCassandraAggregationRepository - Class in org.apache.camel.processor.aggregate.cassandra

Concrete implementation of CassandraAggregationRepository using 2 columns as primary key: name (partition key) and key (clustering key).

NamedCassandraAggregationRepository() - Constructor for class org.apache.camel.processor.aggregate.cassandra.NamedCassandraAggregationRepository

NamedCassandraAggregationRepository(Session, String) - Constructor for class org.apache.camel.processor.aggregate.cassandra.NamedCassandraAggregationRepository

NamedCassandraAggregationRepository(Cluster, String, String) - Constructor for class org.apache.camel.processor.aggregate.cassandra.NamedCassandraAggregationRepository

NamedCassandraIdempotentRepository<K> - Class in org.apache.camel.processor.idempotent.cassandra

Concrete implementation of CassandraIdempotentRepository using 2 columns as primary key: name (partition key) and key (clustering key).

NamedCassandraIdempotentRepository() - Constructor for class org.apache.camel.processor.idempotent.cassandra.NamedCassandraIdempotentRepository

NamedCassandraIdempotentRepository(Session, String) - Constructor for class org.apache.camel.processor.idempotent.cassandra.NamedCassandraIdempotentRepository

NamedCassandraIdempotentRepository(Cluster, String, String) - Constructor for class org.apache.camel.processor.idempotent.cassandra.NamedCassandraIdempotentRepository

O

one() - Static method in class org.apache.camel.component.cassandra.ResultSetConversionStrategies

Retrieve a single row.

org.apache.camel.component.cassandra - package org.apache.camel.component.cassandra

org.apache.camel.processor.aggregate.cassandra - package org.apache.camel.processor.aggregate.cassandra

org.apache.camel.processor.idempotent.cassandra - package org.apache.camel.processor.idempotent.cassandra

org.apache.camel.utils.cassandra - package org.apache.camel.utils.cassandra

P

poll() - Method in class org.apache.camel.component.cassandra.CassandraConsumer

prepareStatement(String) - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

Create and configure a Prepared CQL statement

prepareStatement() - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

Create and configure a Prepared CQL statement

process(Exchange) - Method in class org.apache.camel.component.cassandra.CassandraProducer

R

recover(CamelContext, String) - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

Get exchange by exchange ID.

remove(CamelContext, String, Exchange) - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

Remove exchange by aggregation key from aggregation table.

remove(K) - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

ResultSetConversionStrategies - Class in org.apache.camel.component.cassandra

Implementations of ResultSetConversionStrategy

ResultSetConversionStrategy - Interface in org.apache.camel.component.cassandra

Strategy to convert ResultSet into message body

roundRobinPolicy - Variable in class org.apache.camel.utils.cassandra.CassandraLoadBalancingPolicies

S

scan(CamelContext) - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

Get exchange IDs to be recovered

selectKeyIds() - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

setAllowSerializedHeaders(boolean) - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

setBean(String) - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

Instead of using a hostname:port, refer to an existing configured Session or Cluster from the Camel registry to be used.

setBeanRef(String) - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

Deprecated.

setCluster(Cluster) - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

To use the Cluster instance (you would normally not use this option)

setClusterName(String) - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

Cluster name

setConsistencyLevel(ConsistencyLevel) - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

Consistency level to use

setCql(String) - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

CQL query to perform.

setDeadLetterUri(String) - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

setExchangeColumn(String) - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

setExchangeIdColumn(String) - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

setHosts(String) - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

Hostname(s) cassansdra server(s).

setKeyspace(String) - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

Keyspace to use

setLoadBalancingPolicy(String) - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

setMaximumRedeliveries(int) - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

setName(String) - Method in class org.apache.camel.processor.aggregate.cassandra.NamedCassandraAggregationRepository

setName(String) - Method in class org.apache.camel.processor.idempotent.cassandra.NamedCassandraIdempotentRepository

setPassword(String) - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

Password for session authentication

setPKColumns(String...) - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

setPKColumns(String...) - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

setPort(Integer) - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

Port number of cassansdra server(s)

setPrefixPKValues(Object...) - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

setPrefixPKValues(Object[]) - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

setPrepareStatements(boolean) - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

Whether to use PreparedStatements or regular Statements

setReadConsistencyLevel(ConsistencyLevel) - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

setReadConsistencyLevel(ConsistencyLevel) - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

setRecoveryInterval(long, TimeUnit) - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

setRecoveryInterval(long) - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

setRecoveryIntervalInMillis(long) - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

setResultSetConversionStrategy(ResultSetConversionStrategy) - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

To use a custom class that implements logic for converting ResultSet into message body ALL, ONE, LIMIT_10, LIMIT_100...

setSession(Session) - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

To use the Session instance (you would normally not use this option)

setSession(Session) - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

setSession(Session) - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

setTable(String) - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

setTable(String) - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

setTtl(Integer) - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

setTtl(Integer) - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

setUseRecovery(boolean) - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

setUsername(String) - Method in class org.apache.camel.component.cassandra.CassandraEndpoint

Username for session authentication

setWriteConsistencyLevel(ConsistencyLevel) - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository

setWriteConsistencyLevel(ConsistencyLevel) - Method in class org.apache.camel.processor.idempotent.cassandra.CassandraIdempotentRepository

start() - Method in class org.apache.camel.utils.cassandra.CassandraSessionHolder

stop() - Method in class org.apache.camel.utils.cassandra.CassandraSessionHolder

T

tokenAwarePolicy - Variable in class org.apache.camel.utils.cassandra.CassandraLoadBalancingPolicies

U

unmarshallExchange(CamelContext, ByteBuffer) - Method in class org.apache.camel.processor.aggregate.cassandra.CassandraCamelCodec

A C D F G I L M N O P R S T U