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(EventToIndex eventToIndex, TemplateInitializer initializer, int batchSize, int batchInterval)

Method Summary

Modifier and Type	Method and Description
void	close()
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.

Methods inherited from class java.lang.Object

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

Constructor Detail

EventForwarderQueueImpl

public EventForwarderQueueImpl(EventToIndex eventToIndex,
                               TemplateInitializer initializer,
                               int batchSize,
                               int batchInterval)

Method Detail

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.

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception