Package org.opennms.netmgt.correlation
Class AbstractCorrelationEngine
- java.lang.Object
-
- org.opennms.netmgt.correlation.AbstractCorrelationEngine
-
- All Implemented Interfaces:
CorrelationEngine
- Direct Known Subclasses:
DroolsCorrelationEngine
public abstract class AbstractCorrelationEngine extends java.lang.Object implements CorrelationEngine
Abstract AbstractCorrelationEngine class.
- Version:
- $Id: $
- Author:
- Mathew Brozowski
-
-
Constructor Summary
Constructors Constructor Description AbstractCorrelationEngine()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description voidcancelTimer(java.lang.Integer timerId)cancelTimerabstract voidcorrelate(Event e)correlateabstract java.util.List<java.lang.String>getInterestingEvents()getInterestingEventsintgetPendingTasksCount()java.util.concurrent.ScheduledExecutorServicegetScheduler()abstract voidreloadConfig(boolean persistState)reloadConfigprotected voidrunTimer(org.opennms.netmgt.correlation.AbstractCorrelationEngine.RuleTimerTask task)runTimervoidsendEvent(Event e)sendEventvoidsetEventIpcManager(EventIpcManager eventIpcManager)setEventIpcManagervoidsetScheduler(java.util.concurrent.ScheduledExecutorService scheduler)setSchedulerjava.lang.IntegersetTimer(long millis)setTimerprotected abstract voidtimerExpired(java.lang.Integer timerId)timerExpired-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.opennms.netmgt.correlation.CorrelationEngine
getName, tearDown
-
-
-
-
Method Detail
-
reloadConfig
public abstract void reloadConfig(boolean persistState)
Description copied from interface:CorrelationEnginereloadConfig
- Specified by:
reloadConfigin interfaceCorrelationEngine
-
correlate
public abstract void correlate(Event e)
correlate
- Specified by:
correlatein interfaceCorrelationEngine- Parameters:
e- aEventobject.
-
getInterestingEvents
public abstract java.util.List<java.lang.String> getInterestingEvents()
getInterestingEvents
- Specified by:
getInterestingEventsin interfaceCorrelationEngine- Returns:
- a
Listobject.
-
setEventIpcManager
public void setEventIpcManager(EventIpcManager eventIpcManager)
setEventIpcManager
- Parameters:
eventIpcManager- aEventIpcManagerobject.
-
setTimer
public java.lang.Integer setTimer(long millis)
setTimer
- Parameters:
millis- a long.- Returns:
- a
Integerobject.
-
cancelTimer
public void cancelTimer(java.lang.Integer timerId)
cancelTimer
- Parameters:
timerId- aIntegerobject.
-
getPendingTasksCount
public int getPendingTasksCount()
-
timerExpired
protected abstract void timerExpired(java.lang.Integer timerId)
timerExpired
- Parameters:
timerId- aIntegerobject.
-
setScheduler
public void setScheduler(java.util.concurrent.ScheduledExecutorService scheduler)
setScheduler
- Parameters:
scheduler- aTimerobject.
-
getScheduler
public java.util.concurrent.ScheduledExecutorService getScheduler()
-
runTimer
protected void runTimer(org.opennms.netmgt.correlation.AbstractCorrelationEngine.RuleTimerTask task)
runTimer
- Parameters:
task- aAbstractCorrelationEngine.RuleTimerTaskobject.
-
-