A C D F G I L M N O P R S 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

Cassandra 2 CQL3 endpoint

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

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

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

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.

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

Get exchange from aggregation table by aggregation key.

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

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

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

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

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) - 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

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

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

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

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

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

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

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

setKeyspace(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

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

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

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

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

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

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 U