@UriEndpoint(scheme="elasticsearch",
title="Elasticsearch",
syntax="elasticsearch:clusterName",
producerOnly=true,
label="monitoring,search")
public class ElasticsearchEndpoint
extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
ElasticsearchEndpoint(String uri,
ElasticsearchComponent component,
ElasticsearchConfiguration config,
org.elasticsearch.client.Client client) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
protected void |
doStart() |
protected void |
doStop() |
org.elasticsearch.client.Client |
getClient() |
ElasticsearchConfiguration |
getConfig() |
boolean |
isSingleton() |
void |
setOperation(String operation) |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, 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 ElasticsearchEndpoint(String uri, ElasticsearchComponent component, ElasticsearchConfiguration config, org.elasticsearch.client.Client client) throws Exception
Exception
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public boolean isSingleton()
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultEndpoint
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultEndpoint
Exception
public org.elasticsearch.client.Client getClient()
public ElasticsearchConfiguration getConfig()
public void setOperation(String operation)
Apache Camel