org.opennms.plugins.elasticsearch.rest

Class EventForwarderQueueImpl

java.lang.Object

org.opennms.plugins.elasticsearch.rest.EventForwarderQueueImpl

All Implemented Interfaces:

EventForwarder

public class EventForwarderQueueImpl
extends Object
implements EventForwarder

queues events received from OpenNMS for forwarding to elastic search. drops events if ES not keeping up and queue has become full.

Author:

cgallen

Constructor Summary

Constructors

Constructor and Description
EventForwarderQueueImpl()

Method Summary

Modifier and Type	Method and Description
void	destroy()
ElasticSearchInitialiser	getElasticSearchInitialiser()
EventToIndex	getEventToIndex()
Integer	getMaxQueueLength()
void	init()
void	sendNow(Event event) Called by a service to send an event to eventd
void	sendNow(Log arg0) Called by a service to send a set of events to eventd
void	setElasticSearchInitialiser(ElasticSearchInitialiser elasticSearchInitialiser)
void	setEventToIndex(EventToIndex eventToIndex)
void	setMaxQueueLength(Integer maxQueueLength)

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)

getMaxQueueLength

public Integer getMaxQueueLength()

setMaxQueueLength

public void setMaxQueueLength(Integer maxQueueLength)

sendNow

public void sendNow(Event event)

Description copied from interface: EventForwarder

Called by a service to send an event to eventd

Specified by:

sendNow in interface EventForwarder

Parameters:

event - a Event object.

sendNow

public void sendNow(Log arg0)

Description copied from interface: EventForwarder

Called by a service to send a set of events to eventd

Specified by:

sendNow in interface EventForwarder

Parameters:

arg0 - a Log object.

init

public void init()

destroy

public void destroy()

getElasticSearchInitialiser

public ElasticSearchInitialiser getElasticSearchInitialiser()

Returns:

the elasticSearchInitialiser

setElasticSearchInitialiser

public void setElasticSearchInitialiser(ElasticSearchInitialiser elasticSearchInitialiser)

Parameters:

elasticSearchInitialiser - the elasticSearchInitialiser to set