@UriEndpoint(firstVersion="2.11.0", scheme="spring-redis", title="Spring Redis", syntax="spring-redist:host:port", consumerClass=RedisConsumer.class, label="spring,nosql") public class RedisEndpoint extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
RedisEndpoint(String uri,
RedisComponent component,
RedisConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
protected void |
doShutdown() |
RedisConfiguration |
getConfiguration() |
boolean |
isSingleton() |
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, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public RedisEndpoint(String uri, RedisComponent component, RedisConfiguration configuration)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public boolean isSingleton()
protected void doShutdown() throws Exception
doShutdown
in class org.apache.camel.support.ServiceSupport
Exception
public RedisConfiguration getConfiguration()
Apache Camel