org.apache.camel.component.jcache.processor.aggregate

Class JCacheAggregationRepository

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.component.jcache.processor.aggregate.JCacheAggregationRepository

All Implemented Interfaces:

org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.AggregationRepository, org.apache.camel.spi.OptimisticLockingAggregationRepository, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class JCacheAggregationRepository
extends org.apache.camel.support.ServiceSupport
implements org.apache.camel.spi.OptimisticLockingAggregationRepository

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.camel.spi.OptimisticLockingAggregationRepository

org.apache.camel.spi.OptimisticLockingAggregationRepository.OptimisticLockingException

Field Summary

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

Constructors

Constructor and Description
JCacheAggregationRepository()

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.camel.Exchange	add(org.apache.camel.CamelContext camelContext, String key, org.apache.camel.Exchange exchange)
org.apache.camel.Exchange	add(org.apache.camel.CamelContext camelContext, String key, org.apache.camel.Exchange oldExchange, org.apache.camel.Exchange newExchange)
void	confirm(org.apache.camel.CamelContext camelContext, String exchangeId)
protected void	doStart()
protected void	doStop()
org.apache.camel.Exchange	get(org.apache.camel.CamelContext camelContext, String key)
javax.cache.Cache<String,org.apache.camel.impl.DefaultExchangeHolder>	getCache()
String	getCacheName()
org.apache.camel.CamelContext	getCamelContext()
ClassLoader	getClassLoader()
JCacheConfiguration	getConfiguration()
Set<String>	getKeys()
boolean	isAllowSerializedHeaders()
boolean	isOptimistic()
void	remove(org.apache.camel.CamelContext camelContext, String key, org.apache.camel.Exchange exchange)
void	setAllowSerializedHeaders(boolean allowSerializedHeaders)
void	setCache(javax.cache.Cache<String,org.apache.camel.impl.DefaultExchangeHolder> cache)
void	setCacheName(String cacheName)
void	setCamelContext(org.apache.camel.CamelContext camelContext)
void	setClassLoader(ClassLoader classLoader)
void	setConfiguration(JCacheConfiguration configuration)
void	setOptimistic(boolean optimistic)
protected org.apache.camel.Exchange	unmarshallExchange(org.apache.camel.CamelContext camelContext, org.apache.camel.impl.DefaultExchangeHolder holder)

Methods inherited from class org.apache.camel.support.ServiceSupport

doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, 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

Constructor Detail

JCacheAggregationRepository

public JCacheAggregationRepository()

Method Detail

getConfiguration

public JCacheConfiguration getConfiguration()

setConfiguration

public void setConfiguration(JCacheConfiguration configuration)

getCacheName

public String getCacheName()

setCacheName

public void setCacheName(String cacheName)

getClassLoader

public ClassLoader getClassLoader()

setClassLoader

public void setClassLoader(ClassLoader classLoader)

getCamelContext

public org.apache.camel.CamelContext getCamelContext()

setCamelContext

public void setCamelContext(org.apache.camel.CamelContext camelContext)

getCache

public javax.cache.Cache<String,org.apache.camel.impl.DefaultExchangeHolder> getCache()

setCache

public void setCache(javax.cache.Cache<String,org.apache.camel.impl.DefaultExchangeHolder> cache)

isOptimistic

public boolean isOptimistic()

setOptimistic

public void setOptimistic(boolean optimistic)

isAllowSerializedHeaders

public boolean isAllowSerializedHeaders()

setAllowSerializedHeaders

public void setAllowSerializedHeaders(boolean allowSerializedHeaders)

add

public org.apache.camel.Exchange add(org.apache.camel.CamelContext camelContext,
                            String key,
                            org.apache.camel.Exchange oldExchange,
                            org.apache.camel.Exchange newExchange)
                              throws org.apache.camel.spi.OptimisticLockingAggregationRepository.OptimisticLockingException

Specified by:

add in interface org.apache.camel.spi.OptimisticLockingAggregationRepository

Throws:

org.apache.camel.spi.OptimisticLockingAggregationRepository.OptimisticLockingException

add

public org.apache.camel.Exchange add(org.apache.camel.CamelContext camelContext,
                            String key,
                            org.apache.camel.Exchange exchange)

Specified by:

add in interface org.apache.camel.spi.AggregationRepository

get

public org.apache.camel.Exchange get(org.apache.camel.CamelContext camelContext,
                            String key)

Specified by:

get in interface org.apache.camel.spi.AggregationRepository

remove

public void remove(org.apache.camel.CamelContext camelContext,
          String key,
          org.apache.camel.Exchange exchange)

Specified by:

remove in interface org.apache.camel.spi.AggregationRepository

Specified by:

remove in interface org.apache.camel.spi.OptimisticLockingAggregationRepository

confirm

public void confirm(org.apache.camel.CamelContext camelContext,
           String exchangeId)

Specified by:

confirm in interface org.apache.camel.spi.AggregationRepository

getKeys

public Set<String> getKeys()

Specified by:

getKeys in interface org.apache.camel.spi.AggregationRepository

doStart

protected void doStart()
                throws Exception

Specified by:

doStart in class org.apache.camel.support.ServiceSupport

Throws:

Exception

doStop

protected void doStop()
               throws Exception

Specified by:

doStop in class org.apache.camel.support.ServiceSupport

Throws:

Exception

unmarshallExchange

protected org.apache.camel.Exchange unmarshallExchange(org.apache.camel.CamelContext camelContext,
                                           org.apache.camel.impl.DefaultExchangeHolder holder)