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

Author:

Dennis Oelkers

Constructor Summary

Constructors

Constructor and Description
BatchedElasticSearchOutput(com.codahale.metrics.MetricRegistry metricRegistry, Indexer indexer, Configuration configuration)

Method Summary

Methods

Modifier and Type	Method and Description
void	asynchronousFlush(List<Message> mybuffer)
void	flush()
void	flush(boolean async)
String	getHumanName()
void	synchronousFlush(List<Message> mybuffer)
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,
                                 Indexer indexer,
                                 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

synchronousFlush

public void synchronousFlush(List<Message> mybuffer)

asynchronousFlush

public void asynchronousFlush(List<Message> mybuffer)

flush

public void flush()

flush

public void flush(boolean async)