Package com.adaptris.core.elastic.rest

Class ElasticRestProducer

java.lang.Object

com.adaptris.core.AdaptrisMessageWorkerImp

com.adaptris.core.AdaptrisMessageProducerImp

com.adaptris.core.RequestReplyProducerBase

com.adaptris.core.RequestReplyProducerImp

com.adaptris.core.elastic.rest.ElasticRestProducer

All Implemented Interfaces:

AdaptrisComponent, AdaptrisMessageProducer, AdaptrisMessageSender, AdaptrisMessageWorker, ComponentLifecycle, ComponentLifecycleExtension, MessageEventGenerator

Direct Known Subclasses:

SingleOperation

public abstract class ElasticRestProducer
extends RequestReplyProducerImp

Base class for ElasticSearch based activities.

Field Summary

Fields inherited from class com.adaptris.core.AdaptrisMessageWorkerImp

log

Constructor Summary

Constructors

Constructor	Description
ElasticRestProducer()

Method Summary

Modifier and Type	Method	Description
protected long	defaultTimeout()
protected void	doProduce(AdaptrisMessage msg, java.lang.String endpoint)
java.lang.String	endpoint(AdaptrisMessage msg)
java.lang.String	getIndex()	The elastic index to target
void	prepare()
void	setIndex(java.lang.String index)	The elastic index to target
<T extends ElasticRestProducer> T	withIndex(java.lang.String index)

Methods inherited from class com.adaptris.core.RequestReplyProducerImp

doRequest, produce, request, request

Methods inherited from class com.adaptris.core.RequestReplyProducerBase

copyReplyContents, getIgnoreReplyMetadata, mergeReply, setIgnoreReplyMetadata

Methods inherited from class com.adaptris.core.AdaptrisMessageProducerImp

createName

Methods inherited from class com.adaptris.core.AdaptrisMessageWorkerImp

createQualifier, decode, encode, getEncoder, getIsTrackingEndpoint, getMessageFactory, getUniqueId, handleConnectionException, isTrackingEndpoint, registerConnection, registerEncoderMessageFactory, retrieveConnection, setEncoder, setIsTrackingEndpoint, setMessageFactory, setUniqueId, withMessageFactory, withUniqueID

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.adaptris.core.AdaptrisComponent

getUniqueId

Methods inherited from interface com.adaptris.core.AdaptrisMessageWorker

decode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactory

Methods inherited from interface com.adaptris.core.ComponentLifecycle

close, init, start, stop

Methods inherited from interface com.adaptris.core.MessageEventGenerator

createQualifier, isTrackingEndpoint

Constructor Detail

ElasticRestProducer

public ElasticRestProducer()

Method Detail

prepare

public void prepare()
             throws CoreException

Throws:

CoreException

defaultTimeout

protected long defaultTimeout()

Specified by:

defaultTimeout in class RequestReplyProducerBase

withIndex

public <T extends ElasticRestProducer> T withIndex(java.lang.String index)

doProduce

protected void doProduce(AdaptrisMessage msg,
                         java.lang.String endpoint)
                  throws ProduceException

Specified by:

doProduce in class RequestReplyProducerImp

Throws:

ProduceException

endpoint

public java.lang.String endpoint(AdaptrisMessage msg)
                          throws ProduceException

Specified by:

endpoint in class AdaptrisMessageProducerImp

Throws:

ProduceException

getIndex

public java.lang.String getIndex()

The elastic index to target

setIndex

public void setIndex(java.lang.String index)

The elastic index to target