org.opennms.plugins.elasticsearch.rest

Class EventForwarderQueueImpl

java.lang.Object

org.opennms.plugins.elasticsearch.rest.EventForwarderQueueImpl

All Implemented Interfaces:

AutoCloseable, EventForwarder

public class EventForwarderQueueImpl
extends Object
implements EventForwarder, AutoCloseable

Queues events received from OpenNMS for forwarding to Elasticsearch.

Author:

cgallen, Seth

Constructor Summary

Constructors

Constructor and Description
EventForwarderQueueImpl()

Method Summary

Modifier and Type	Method and Description
void	close()
int	getBatchInterval()
int	getBatchSize()
ElasticSearchInitialiser	getElasticSearchInitialiser()
EventToIndex	getEventToIndex()
void	init()
void	sendNow(Event event) Asynchronously sends an event to eventd.
void	sendNow(Log eventLog) Asynchronously sends a set of events to eventd.
void	sendNowSync(Event event) Call AggregatingMessageProducer.dispatch(Object) to synchronously dispatch the event.
void	sendNowSync(Log eventLog) Call AggregatingMessageProducer.dispatch(Object) to synchronously dispatch the events.
void	setBatchInterval(int batchInterval)
void	setBatchSize(int batchSize)
void	setElasticSearchInitialiser(ElasticSearchInitialiser elasticSearchInitialiser)
void	setEventToIndex(EventToIndex eventToIndex)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventForwarderQueueImpl

public EventForwarderQueueImpl()

Method Detail

getEventToIndex

public EventToIndex getEventToIndex()

setEventToIndex

public void setEventToIndex(EventToIndex eventToIndex)

sendNow

public void sendNow(Event event)

Description copied from interface: EventForwarder

Asynchronously sends an event to eventd.

Specified by:

sendNow in interface EventForwarder

Parameters:

event - a Event object.

sendNow

public void sendNow(Log eventLog)

Description copied from interface: EventForwarder

Asynchronously sends a set of events to eventd.

Specified by:

sendNow in interface EventForwarder

Parameters:

eventLog - a Log object.

sendNowSync

public void sendNowSync(Event event)

Call AggregatingMessageProducer.dispatch(Object) to synchronously dispatch the event.

Specified by:

sendNowSync in interface EventForwarder

Parameters:

event - a Event object.

sendNowSync

public void sendNowSync(Log eventLog)

Call AggregatingMessageProducer.dispatch(Object) to synchronously dispatch the events.

Specified by:

sendNowSync in interface EventForwarder

Parameters:

eventLog - a Log object.

init

public void init()

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

getBatchSize

public int getBatchSize()

setBatchSize

public void setBatchSize(int batchSize)

getBatchInterval

public int getBatchInterval()

setBatchInterval

public void setBatchInterval(int batchInterval)

getElasticSearchInitialiser

public ElasticSearchInitialiser getElasticSearchInitialiser()

Returns:

the elasticSearchInitialiser

setElasticSearchInitialiser

public void setElasticSearchInitialiser(ElasticSearchInitialiser elasticSearchInitialiser)

Parameters:

elasticSearchInitialiser - the elasticSearchInitialiser to set