public class ElasticSearchOutput extends java.lang.Object implements MessageOutput
| Constructor and Description |
|---|
ElasticSearchOutput(com.codahale.metrics.MetricRegistry metricRegistry,
Messages messages) |
| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
getHumanName() |
java.lang.String |
getLinkToDocs() |
java.lang.String |
getName() |
ConfigurationRequest |
getRequestedConfiguration() |
void |
initialize(Configuration config) |
boolean |
isRunning() |
void |
stop() |
void |
write(java.util.List<Message> messageList) |
void |
write(Message message) |
@Inject
public ElasticSearchOutput(com.codahale.metrics.MetricRegistry metricRegistry,
Messages messages)
public void write(Message message) throws java.lang.Exception
write in interface MessageOutputjava.lang.Exceptionpublic void write(java.util.List<Message> messageList) throws java.lang.Exception
write in interface MessageOutputjava.lang.Exceptionpublic java.lang.String getName()
getName in interface MessageOutputpublic void initialize(Configuration config) throws MessageOutputConfigurationException
initialize in interface MessageOutputMessageOutputConfigurationExceptionpublic void stop()
stop in interface MessageOutputpublic boolean isRunning()
isRunning in interface MessageOutputpublic ConfigurationRequest getRequestedConfiguration()
getRequestedConfiguration in interface MessageOutputpublic java.lang.String getHumanName()
getHumanName in interface MessageOutputpublic java.lang.String getLinkToDocs()
getLinkToDocs in interface MessageOutputCopyright © 2012-2014 TORCH GmbH. All Rights Reserved.