@UriEndpoint(firstVersion="2.6.0", scheme="kestrel", title="Kestrel", syntax="kestrel:addresses/queue", consumerClass=KestrelConsumer.class, label="messaging") public class KestrelEndpoint extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
KestrelEndpoint(String endPointURI,
KestrelComponent component,
KestrelConfiguration configuration,
String queue) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
KestrelConfiguration |
getConfiguration() |
String |
getQueue() |
boolean |
isSingleton() |
void |
setConfiguration(KestrelConfiguration configuration) |
void |
setQueue(String queue) |
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, stop, suspend
public KestrelEndpoint(String endPointURI, KestrelComponent component, KestrelConfiguration configuration, String queue)
public KestrelConfiguration getConfiguration()
public void setConfiguration(KestrelConfiguration configuration)
public String getQueue()
public void setQueue(String queue)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public boolean isSingleton()
Apache Camel