Class NamedCassandraAggregationRepository
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository
-
- org.apache.camel.processor.aggregate.cassandra.NamedCassandraAggregationRepository
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.spi.AggregationRepository
,org.apache.camel.spi.RecoverableAggregationRepository
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
public class NamedCassandraAggregationRepository extends CassandraAggregationRepository
Concrete implementation ofCassandraAggregationRepository
using 2 columns as primary key: name (partition key) and key (clustering key).
-
-
Constructor Summary
Constructors Constructor Description NamedCassandraAggregationRepository()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String
getName()
void
setName(String name)
-
Methods inherited from class org.apache.camel.processor.aggregate.cassandra.CassandraAggregationRepository
add, confirm, doStart, doStop, get, getDeadLetterUri, getExchangeColumn, getExchangeIdColumn, getKeys, getMaximumRedeliveries, getPKColumns, getPKValues, getPrefixPKValues, getReadConsistencyLevel, getRecoveryIntervalInMillis, getSession, getTable, getTtl, getWriteConsistencyLevel, initSelectStatement, isAllowSerializedHeaders, isUseRecovery, recover, remove, scan, selectKeyIds, setAllowSerializedHeaders, setDeadLetterUri, setExchangeColumn, setExchangeIdColumn, setMaximumRedeliveries, setPKColumns, setPrefixPKValues, setReadConsistencyLevel, setRecoveryInterval, setRecoveryInterval, setRecoveryIntervalInMillis, setSession, setTable, setTtl, setUseRecovery, setWriteConsistencyLevel
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doInit, doLifecycleChange, doResume, doShutdown, doSuspend, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
-