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.
 
 - 
 
 -