org.graylog2.outputs

Class BatchedElasticSearchOutput

java.lang.Object

org.graylog2.outputs.ElasticSearchOutput

org.graylog2.outputs.BatchedElasticSearchOutput

All Implemented Interfaces:

MessageOutput

public class BatchedElasticSearchOutput
extends ElasticSearchOutput

Constructor Summary

Constructors

Constructor and Description
BatchedElasticSearchOutput(com.codahale.metrics.MetricRegistry metricRegistry, Messages messages, Cluster cluster, Configuration configuration)

Method Summary

Modifier and Type	Method and Description
void	flush()
String	getHumanName()
void	write(Message message)

Methods inherited from class org.graylog2.outputs.ElasticSearchOutput

getLinkToDocs, getName, getRequestedConfiguration, initialize, isRunning, stop, write

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchedElasticSearchOutput

@Inject
public BatchedElasticSearchOutput(com.codahale.metrics.MetricRegistry metricRegistry,
                                          Messages messages,
                                          Cluster cluster,
                                          Configuration configuration)

Method Detail

write

public void write(Message message)
           throws Exception

Specified by:

write in interface MessageOutput

Overrides:

write in class ElasticSearchOutput

Throws:

Exception

getHumanName

public String getHumanName()

Specified by:

getHumanName in interface MessageOutput

Overrides:

getHumanName in class ElasticSearchOutput

flush

public void flush()