org.opennms.plugins.elasticsearch.rest.archive

Class OnmsHistoricEventsToEs

java.lang.Object

org.opennms.plugins.elasticsearch.rest.archive.OnmsHistoricEventsToEs

public class OnmsHistoricEventsToEs
extends Object

takes events from OpenNMS historic events through the OpennMS rest interface and sends them to Elasticsearch using the same queue as live incoming events use.

Author:

admin

Constructor Summary

Constructors

Constructor and Description
OnmsHistoricEventsToEs()

Method Summary

Modifier and Type	Method and Description
EventForwarder	getEventForwarder()
Integer	getLimit()
Integer	getOffset()
String	getOnmsPassWord()
String	getOnmsUrl()
String	getOnmsUserName()
boolean	getUseNodeLabel()
String	sendEventsToEs() sends events to Elasticsearch returns true if successful
void	setEventForwarder(EventForwarder eventForwarder)
void	setLimit(Integer limit)
void	setLogSize(int logSize)
void	setOffset(Integer offset)
void	setOnmsPassWord(String onmsPassWord)
void	setOnmsUrl(String onmsUrl)
void	setOnmsUserName(String onmsUserName)
void	setUseNodeLabel(boolean useCache)

Methods inherited from class java.lang.Object

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

Constructor Detail

OnmsHistoricEventsToEs

public OnmsHistoricEventsToEs()

Method Detail

getOnmsUrl

public String getOnmsUrl()

setOnmsUrl

public void setOnmsUrl(String onmsUrl)

getOnmsUserName

public String getOnmsUserName()

setOnmsUserName

public void setOnmsUserName(String onmsUserName)

getOnmsPassWord

public String getOnmsPassWord()

setOnmsPassWord

public void setOnmsPassWord(String onmsPassWord)

getEventForwarder

public EventForwarder getEventForwarder()

setEventForwarder

public void setEventForwarder(EventForwarder eventForwarder)

getLimit

public Integer getLimit()

setLimit

public void setLimit(Integer limit)

getOffset

public Integer getOffset()

setOffset

public void setOffset(Integer offset)

getUseNodeLabel

public boolean getUseNodeLabel()

setUseNodeLabel

public void setUseNodeLabel(boolean useCache)

setLogSize

public void setLogSize(int logSize)

sendEventsToEs

public String sendEventsToEs()

sends events to Elasticsearch returns true if successful

Returns: