com.serotonin.mango.rt

Class EventManager

java.lang.Object

com.serotonin.mango.rt.EventManager

All Implemented Interfaces:

com.serotonin.util.ILifecycle

public class EventManager
extends java.lang.Object
implements com.serotonin.util.ILifecycle

Author:

Matthew Lohbihler

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	EventManager.MyMap<K,V>
(package private) class	EventManager.MySet<T>

Field Summary

Fields

Modifier and Type	Field and Description
private EventManager.MySet<java.lang.Integer>	activeDatapointIds
private java.util.List<EventInstance>	activeEvents
private java.util.Map<java.lang.Integer,java.util.concurrent.atomic.AtomicInteger>	activeUserEventCount
private EventDao	eventDao
private EventManager.MyMap<java.lang.Integer,java.util.List<java.lang.Integer>>	eventUserPair
private int	highestActiveAlarmLevel
private long	lastAlarmTimestamp
private org.apache.commons.logging.Log	log
private UserCache	userCache

Constructor Summary

Constructors

Constructor and Description
EventManager()

Method Summary

Modifier and Type	Method and Description
void	cancelEventsForDataPoint(int dataPointId)
void	cancelEventsForDataSource(int dataSourceId)
void	cancelEventsForPublisher(int publisherId)
boolean	datapointHasActiveEvent(int dpId)
private void	deactivateEvent(EventInstance evt, long time, int inactiveCause)
private EventInstance	get(EventType type) Returns the first event instance with the given type, or null is there is none.
java.lang.Integer	getActiveAlarmCountPerUser(java.lang.Integer userId)
java.util.List<EventInstance>	getActiveEventsByUser(int userId)
private com.serotonin.web.i18n.LocalizableMessage	getAlarmLevelChangeMessage(java.lang.String key, int oldValue)
private java.util.List<EventInstance>	getAll(EventType type)
int	getHighestActiveEventLevelByUser(int userId)
long	getLastAlarmTimestamp()
private void	handleInactiveEvent(EventInstance evt)
private void	handleRaiseEvent(EventInstance evt, java.util.Set<java.lang.String> defaultAddresses)
void	initialize()
private boolean	isSuppressed(EventType eventType)
void	joinTermination()
void	raiseEvent(EventType type, long time, boolean rtnApplicable, int alarmLevel, com.serotonin.web.i18n.LocalizableMessage message, java.util.Map<java.lang.String,java.lang.Object> context)
private EventInstance	remove(EventType type) Finds and removes the first event instance with the given type.
private void	removeFromControlLists(EventInstance e)
private void	resetHighestAlarmLevel(long time, boolean init)
void	returnToNormal(EventType type, long time)
void	returnToNormal(EventType type, long time, int cause)
private void	setHandlers(EventInstance evt)
void	terminate()

Methods inherited from class java.lang.Object

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

Field Detail

log

private final org.apache.commons.logging.Log log

activeEvents

private final java.util.List<EventInstance> activeEvents

activeDatapointIds

private final EventManager.MySet<java.lang.Integer> activeDatapointIds

activeUserEventCount

private final java.util.Map<java.lang.Integer,java.util.concurrent.atomic.AtomicInteger> activeUserEventCount

eventUserPair

private final EventManager.MyMap<java.lang.Integer,java.util.List<java.lang.Integer>> eventUserPair

eventDao

private EventDao eventDao

userCache

private UserCache userCache

lastAlarmTimestamp

private long lastAlarmTimestamp

highestActiveAlarmLevel

private int highestActiveAlarmLevel

Constructor Detail

EventManager

public EventManager()

Method Detail

raiseEvent

public void raiseEvent(EventType type,
                       long time,
                       boolean rtnApplicable,
                       int alarmLevel,
                       com.serotonin.web.i18n.LocalizableMessage message,
                       java.util.Map<java.lang.String,java.lang.Object> context)

returnToNormal

public void returnToNormal(EventType type,
                           long time)

returnToNormal

public void returnToNormal(EventType type,
                           long time,
                           int cause)

deactivateEvent

private void deactivateEvent(EventInstance evt,
                             long time,
                             int inactiveCause)

getLastAlarmTimestamp

public long getLastAlarmTimestamp()

cancelEventsForDataPoint

public void cancelEventsForDataPoint(int dataPointId)

cancelEventsForDataSource

public void cancelEventsForDataSource(int dataSourceId)

cancelEventsForPublisher

public void cancelEventsForPublisher(int publisherId)

resetHighestAlarmLevel

private void resetHighestAlarmLevel(long time,
                                    boolean init)

getAlarmLevelChangeMessage

private com.serotonin.web.i18n.LocalizableMessage getAlarmLevelChangeMessage(java.lang.String key,
                                                                             int oldValue)

initialize

public void initialize()

Specified by:

initialize in interface com.serotonin.util.ILifecycle

terminate

public void terminate()

Specified by:

terminate in interface com.serotonin.util.ILifecycle

joinTermination

public void joinTermination()

Specified by:

joinTermination in interface com.serotonin.util.ILifecycle

get

private EventInstance get(EventType type)

Returns the first event instance with the given type, or null is there is none.

getAll

private java.util.List<EventInstance> getAll(EventType type)

remove

private EventInstance remove(EventType type)

Finds and removes the first event instance with the given type. Returns null if there is none.

Parameters:

type -

Returns:

removeFromControlLists

private void removeFromControlLists(EventInstance e)

setHandlers

private void setHandlers(EventInstance evt)

handleRaiseEvent

private void handleRaiseEvent(EventInstance evt,
                              java.util.Set<java.lang.String> defaultAddresses)

handleInactiveEvent

private void handleInactiveEvent(EventInstance evt)

isSuppressed

private boolean isSuppressed(EventType eventType)

getActiveAlarmCountPerUser

public java.lang.Integer getActiveAlarmCountPerUser(java.lang.Integer userId)

datapointHasActiveEvent

public boolean datapointHasActiveEvent(int dpId)

getActiveEventsByUser

public java.util.List<EventInstance> getActiveEventsByUser(int userId)

getHighestActiveEventLevelByUser

public int getHighestActiveEventLevelByUser(int userId)