org.fusesource.insight.graph.es
Class ElasticSearchOutputWriter

java.lang.Object
  com.googlecode.jmxtrans.util.BaseOutputWriter
      org.fusesource.insight.graph.es.ElasticSearchOutputWriter

All Implemented Interfaces:

com.googlecode.jmxtrans.OutputWriter, org.osgi.util.tracker.ServiceTrackerCustomizer<org.elasticsearch.node.Node,org.elasticsearch.node.Node>

public class ElasticSearchOutputWriter
extends com.googlecode.jmxtrans.util.BaseOutputWriter
implements com.googlecode.jmxtrans.OutputWriter, org.osgi.util.tracker.ServiceTrackerCustomizer<org.elasticsearch.node.Node,org.elasticsearch.node.Node>

Field Summary

Fields inherited from class com.googlecode.jmxtrans.util.BaseOutputWriter

BINARY_PATH, DEBUG, HOST, OUTPUT_FILE, PORT, TEMPLATE_FILE, TYPE_NAMES

Constructor Summary

ElasticSearchOutputWriter()

Method Summary

org.elasticsearch.node.Node	addingService(org.osgi.framework.ServiceReference<org.elasticsearch.node.Node> nodeServiceReference)
void	doWrite(com.googlecode.jmxtrans.model.Query query)
java.lang.String	getStringSetting(java.lang.String key, java.lang.String defaultVal)
void	modifiedService(org.osgi.framework.ServiceReference<org.elasticsearch.node.Node> nodeServiceReference, org.elasticsearch.node.Node node)
void	removedService(org.osgi.framework.ServiceReference<org.elasticsearch.node.Node> nodeServiceReference, org.elasticsearch.node.Node node)
void	start()
void	stop()
void	validateSetup(com.googlecode.jmxtrans.model.Query query)

Methods inherited from class com.googlecode.jmxtrans.util.BaseOutputWriter

addSetting, addTypeName, cleanupStr, getBooleanSetting, getConcatedTypeNameValues, getSettings, getTypeNames, isDebugEnabled, setObjectPoolMap, setSettings, setTypeNames

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.googlecode.jmxtrans.OutputWriter

getSettings, setObjectPoolMap, setSettings

Constructor Detail

ElasticSearchOutputWriter

public ElasticSearchOutputWriter()

Method Detail

start

public void start()
           throws com.googlecode.jmxtrans.util.LifecycleException

Specified by:

start in interface com.googlecode.jmxtrans.OutputWriter

Overrides:

start in class com.googlecode.jmxtrans.util.BaseOutputWriter

Throws:

com.googlecode.jmxtrans.util.LifecycleException

stop

public void stop()
          throws com.googlecode.jmxtrans.util.LifecycleException

Specified by:

stop in interface com.googlecode.jmxtrans.OutputWriter

Overrides:

stop in class com.googlecode.jmxtrans.util.BaseOutputWriter

Throws:

com.googlecode.jmxtrans.util.LifecycleException

addingService

public org.elasticsearch.node.Node addingService(org.osgi.framework.ServiceReference<org.elasticsearch.node.Node> nodeServiceReference)

Specified by:

addingService in interface org.osgi.util.tracker.ServiceTrackerCustomizer<org.elasticsearch.node.Node,org.elasticsearch.node.Node>

modifiedService

public void modifiedService(org.osgi.framework.ServiceReference<org.elasticsearch.node.Node> nodeServiceReference,
                            org.elasticsearch.node.Node node)

Specified by:

modifiedService in interface org.osgi.util.tracker.ServiceTrackerCustomizer<org.elasticsearch.node.Node,org.elasticsearch.node.Node>

removedService

public void removedService(org.osgi.framework.ServiceReference<org.elasticsearch.node.Node> nodeServiceReference,
                           org.elasticsearch.node.Node node)

Specified by:

removedService in interface org.osgi.util.tracker.ServiceTrackerCustomizer<org.elasticsearch.node.Node,org.elasticsearch.node.Node>

validateSetup

public void validateSetup(com.googlecode.jmxtrans.model.Query query)
                   throws com.googlecode.jmxtrans.util.ValidationException

Specified by:

validateSetup in interface com.googlecode.jmxtrans.OutputWriter

Throws:

com.googlecode.jmxtrans.util.ValidationException

doWrite

public void doWrite(com.googlecode.jmxtrans.model.Query query)
             throws java.lang.Exception

Specified by:

doWrite in interface com.googlecode.jmxtrans.OutputWriter

Throws:

java.lang.Exception

getStringSetting

public java.lang.String getStringSetting(java.lang.String key,
                                         java.lang.String defaultVal)