@UriEndpoint(scheme="gora", title="Gora", syntax="gora:name", consumerClass=GoraConsumer.class, label="database,hadoop,nosql") public class GoraEndpoint extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
GoraEndpoint(String uri,
GoraComponent goraComponent,
GoraConfiguration config,
org.apache.gora.store.DataStore<Object,org.apache.gora.persistency.Persistent> dataStore)
GORA endpoint default constructor
|
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
GoraConfiguration |
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, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public GoraEndpoint(String uri, GoraComponent goraComponent, GoraConfiguration config, org.apache.gora.store.DataStore<Object,org.apache.gora.persistency.Persistent> dataStore)
uri
- Endpoint URIgoraComponent
- Reference to the Camel-Gora componentconfig
- Reference to Camel-Gora endpoint configurationdataStore
- Reference to Gora DataStorepublic org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public GoraConfiguration getConfiguration()
public boolean isSingleton()
Apache Camel