public class ElasticsearchProducer
extends org.apache.camel.impl.DefaultProducer
Modifier and Type | Field and Description |
---|---|
protected ElasticsearchConfiguration |
configuration |
Constructor and Description |
---|
ElasticsearchProducer(ElasticsearchEndpoint endpoint,
ElasticsearchConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
org.elasticsearch.client.transport.TransportClient |
getClient() |
void |
process(org.apache.camel.Exchange exchange) |
createExchange, createExchange, createExchange, getEndpoint, isSingleton, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
protected final ElasticsearchConfiguration configuration
public ElasticsearchProducer(ElasticsearchEndpoint endpoint, ElasticsearchConfiguration configuration)
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultProducer
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultProducer
Exception
public org.elasticsearch.client.transport.TransportClient getClient()
Apache Camel