@UriEndpoint(firstVersion="2.19.0", scheme="azure-queue", title="Azure Storage Queue Service", syntax="azure-blob:containerAndQueueUri", consumerClass=QueueServiceConsumer.class, label="cloud,queue,azure") public class QueueServiceEndpoint extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
QueueServiceEndpoint(String uri,
org.apache.camel.Component comp,
QueueServiceConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
QueueServiceConfiguration |
getConfiguration() |
boolean |
isSingleton() |
void |
setConfiguration(QueueServiceConfiguration configuration) |
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 QueueServiceEndpoint(String uri, org.apache.camel.Component comp, QueueServiceConfiguration configuration)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public boolean isSingleton()
public QueueServiceConfiguration getConfiguration()
public void setConfiguration(QueueServiceConfiguration configuration)
Apache Camel