@UriEndpoint(firstVersion="2.1.0", scheme="cache", title="EHCache", syntax="cache:cacheName", consumerClass=CacheConsumer.class, label="cache") public class CacheEndpoint extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
CacheEndpoint() |
CacheEndpoint(String endpointUri,
org.apache.camel.Component component,
CacheConfiguration config,
CacheManagerFactory cacheManagerFactory) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Exchange |
createCacheExchange(String operation,
String key,
Object value) |
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
CacheManagerFactory |
getCacheManagerFactory() |
CacheConfiguration |
getConfig() |
String |
getKey() |
String |
getOperation() |
net.sf.ehcache.Ehcache |
initializeCache()
Returns
Cache instance or create new one if not exists. |
boolean |
isSingleton() |
void |
setCacheManagerFactory(CacheManagerFactory cacheManagerFactory)
To use a custom CacheManagerFactory for creating the CacheManager to be used by this endpoint.
|
void |
setConfig(CacheConfiguration config) |
void |
setKey(String key)
The default key to use.
|
void |
setOperation(String operation)
The default cache operation to use.
|
void |
stop() |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, suspend
public CacheEndpoint()
public CacheEndpoint(String endpointUri, org.apache.camel.Component component, CacheConfiguration config, CacheManagerFactory cacheManagerFactory)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public boolean isSingleton()
public CacheConfiguration getConfig()
public void setConfig(CacheConfiguration config)
public CacheManagerFactory getCacheManagerFactory()
public void setCacheManagerFactory(CacheManagerFactory cacheManagerFactory)
public org.apache.camel.Exchange createCacheExchange(String operation, String key, Object value)
public net.sf.ehcache.Ehcache initializeCache()
Cache
instance or create new one if not exists.Cache
public void stop()
stop
in interface org.apache.camel.Service
stop
in class org.apache.camel.support.ServiceSupport
public String getOperation()
public void setOperation(String operation)
public String getKey()
public void setKey(String key)
Apache Camel