Package org.graylog2.outputs

Class ElasticSearchOutput

java.lang.Object

org.graylog2.outputs.ElasticSearchOutput

All Implemented Interfaces:

FilteredMessageOutput, MessageOutput, Stoppable

@Singleton
public class ElasticSearchOutput
extends Object
implements MessageOutput, FilteredMessageOutput

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ElasticSearchOutput.Config
static class	ElasticSearchOutput.Descriptor
static interface	ElasticSearchOutput.Factory

Nested classes/interfaces inherited from interface org.graylog2.plugin.outputs.MessageOutput

MessageOutput.Factory2<T>

Field Summary

Fields

Modifier and Type	Field	Description
static final String	FILTER_KEY

Constructor Summary

Constructors

Constructor	Description
ElasticSearchOutput(com.codahale.metrics.MetricRegistry metricRegistry, Messages messages)

Method Summary

Modifier and Type	Method	Description
boolean	isRunning()
void	stop()
void	write(List<Message> messageList)
void	write(Message message)
void	writeFiltered(List<FilteredMessage> filteredMessages)	Write the given filtered messages.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.graylog2.plugin.outputs.MessageOutput

initialize

Field Details

FILTER_KEY

public static final String FILTER_KEY

See Also:

• Constant Field Values

Constructor Details

ElasticSearchOutput

@Inject
public ElasticSearchOutput(com.codahale.metrics.MetricRegistry metricRegistry,
 Messages messages)

Method Details

writeFiltered

public void writeFiltered(List<FilteredMessage> filteredMessages)
                   throws Exception

Description copied from interface: FilteredMessageOutput

Write the given filtered messages. Based on the filtered messages attributes, the output can decide to discard the message.

Specified by:

writeFiltered in interface FilteredMessageOutput

Parameters:

filteredMessages - the filtered messages

Throws:

Exception - if writing the messages fails

write

public void write(Message message)
           throws Exception

Specified by:

write in interface MessageOutput

Throws:

Exception

write

public void write(List<Message> messageList)
           throws Exception

Specified by:

write in interface MessageOutput

Throws:

Exception

stop

public void stop()

Specified by:

stop in interface Stoppable

isRunning

public boolean isRunning()

Specified by:

isRunning in interface MessageOutput