@UriEndpoint(firstVersion="2.19.0",
scheme="elasticsearch5",
title="Elasticsearch5",
syntax="elasticsearch5:clusterName",
producerOnly=true,
label="monitoring,search")
public class ElasticsearchEndpoint
extends org.apache.camel.impl.DefaultEndpoint
Modifier and Type | Field and Description |
---|---|
protected ElasticsearchConfiguration |
configuration |
Constructor and Description |
---|
ElasticsearchEndpoint(String uri,
ElasticsearchComponent component,
ElasticsearchConfiguration config,
org.elasticsearch.client.transport.TransportClient client) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
org.elasticsearch.client.transport.TransportClient |
getClient() |
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
@UriParam protected final ElasticsearchConfiguration configuration
public ElasticsearchEndpoint(String uri, ElasticsearchComponent component, ElasticsearchConfiguration config, org.elasticsearch.client.transport.TransportClient client) throws Exception
Exception
Apache Camel