public class KestrelComponent
extends org.apache.camel.impl.UriEndpointComponent
Constructor and Description |
---|
KestrelComponent() |
KestrelComponent(org.apache.camel.CamelContext context) |
KestrelComponent(KestrelConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
void |
closeMemcachedClient(String key,
net.spy.memcached.MemcachedClient memcachedClient) |
protected KestrelEndpoint |
createEndpoint(String uri,
String remaining,
Map<String,Object> parameters) |
protected void |
doStart() |
protected void |
doStop() |
KestrelConfiguration |
getConfiguration() |
net.spy.memcached.MemcachedClient |
getMemcachedClient(KestrelConfiguration config,
String queue) |
void |
setConfiguration(KestrelConfiguration configuration)
To use a shared configured configuration as base for creating new endpoints.
|
createComponentConfiguration, createParameterConfigurationMap, getEndpointClass, getParameterConfigurationMap, populateParameterConfigurationMap, setEndpointClass
afterConfiguration, createConfiguration, createEndpoint, getAndRemoveOrResolveReferenceParameter, getAndRemoveOrResolveReferenceParameter, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, getExtension, getSupportedExtensions, ifStartsWithReturnRemainder, isResolvePropertyPlaceholders, preProcessUri, registerExtension, registerExtension, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, setCamelContext, setProperties, setProperties, setResolvePropertyPlaceholders, useIntrospectionOnEndpoint, useRawUri, validateParameters, validateURI
public KestrelComponent()
public KestrelComponent(KestrelConfiguration configuration)
public KestrelComponent(org.apache.camel.CamelContext context)
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultComponent
Exception
public KestrelConfiguration getConfiguration()
public void setConfiguration(KestrelConfiguration configuration)
protected KestrelEndpoint createEndpoint(String uri, String remaining, Map<String,Object> parameters) throws Exception
createEndpoint
in class org.apache.camel.impl.DefaultComponent
Exception
public net.spy.memcached.MemcachedClient getMemcachedClient(KestrelConfiguration config, String queue)
public void closeMemcachedClient(String key, net.spy.memcached.MemcachedClient memcachedClient)
Apache Camel