@UriEndpoint(firstVersion="2.15.0", scheme="atmos", title="Atmos", syntax="atmos:name/operation", consumerClass=AtmosScheduledPollConsumer.class, label="file,cloud") public class AtmosEndpoint extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
AtmosEndpoint() |
AtmosEndpoint(String endpointUri) |
AtmosEndpoint(String uri,
AtmosComponent component,
AtmosConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor)
Create one of the camel consumer available based on the configuration
|
org.apache.camel.Producer |
createProducer()
Create one of the camel producer available based on the configuration
|
AtmosConfiguration |
getConfiguration() |
boolean |
isSingleton() |
void |
setConfiguration(AtmosConfiguration 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 AtmosEndpoint()
public AtmosEndpoint(String uri, AtmosComponent component, AtmosConfiguration configuration)
public AtmosEndpoint(String endpointUri)
public AtmosConfiguration getConfiguration()
public void setConfiguration(AtmosConfiguration configuration)
public org.apache.camel.Producer createProducer() throws Exception
Exception
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
processor
- the given processorException
public boolean isSingleton()
Apache Camel