public class ACSAlarmDAOImpl extends java.lang.Object implements AlarmDAO
The alarms are stored in an HashMap having the triplet as key. The default member has a triplet with a "*" replacing its name.
The sources are defined together with an alarm definition so they are read here and requested by the ACSSourceDAOImpl at startup (instead of being read again from CDB).
The initialization of the alarms is not completely done by loadAlarms because not all the info are available at this time. In fact the categories are assigned to alarms by ACSCategoryDAOImpl
For the assigning alarms to reduction rules, the class take advantage of the fact that a parent in a reduction rule never contains regular expressions nor wildcards.
ACSSourceDAOImpl,
ACSCategoryDAOImpl| Constructor and Description |
|---|
ACSAlarmDAOImpl(java.util.logging.Logger log)
Constructor
|
| Modifier and Type | Method and Description |
|---|---|
java.util.Collection |
archiveSearch(java.lang.String select_sql) |
void |
deleteAlarm(Alarm alarm) |
Alarm |
findAlarm(java.lang.String alarmId)
Returns the alarm corresponding to the given id.
|
java.lang.String[] |
findAlarmIdsByPriority(java.lang.Integer priority) |
Building |
findBuilding(java.lang.String building) |
java.lang.String |
findLaserSurveillanceAlarmId()
Returns all alarms.
|
Alarm |
getAlarm(java.lang.String alarmId)
Get an alarm from the cache.
|
java.lang.String[] |
getAllAlarmIDs() |
ReductionDefinitions |
getReductionDefinitions() |
java.util.concurrent.ConcurrentHashMap<java.lang.String,Source> |
getSources()
Getter method
|
java.util.List<FaultFamily> |
loadAlarms()
Load alarms from CDB.
|
void |
saveAlarm(Alarm alarm) |
void |
saveMemberAlarms(java.lang.String member) |
java.util.Collection |
search(java.lang.String select_sql) |
void |
setAlarmCache(ACSAlarmCacheImpl alarmCache) |
void |
setAlarmProcessor(AlarmMessageProcessorImpl processor) |
void |
setConfAccessor(ConfigurationAccessor conf) |
void |
setResponsiblePersonDAO(ResponsiblePersonDAO responsiblePersonDAO) |
void |
setSurveillanceAlarmId(java.lang.String surveillanceAlarmId) |
void |
updateAlarm(Alarm alarm) |
void |
updateStatus(Status status) |
public ACSAlarmDAOImpl(java.util.logging.Logger log)
log - The log (not null)public java.util.List<FaultFamily> loadAlarms()
throws java.lang.Exception
java.lang.Exception - In case of error while parsing XML definition filesACSCategoryDAOImplpublic ReductionDefinitions getReductionDefinitions()
public Alarm findAlarm(java.lang.String alarmId)
AlarmDAOpublic Alarm getAlarm(java.lang.String alarmId)
getAlarm in interface AlarmDAOalarmId - The ID of the alarmpublic java.lang.String[] findAlarmIdsByPriority(java.lang.Integer priority)
findAlarmIdsByPriority in interface AlarmDAOpublic java.lang.String findLaserSurveillanceAlarmId()
AlarmDAOfindLaserSurveillanceAlarmId in interface AlarmDAOpublic void deleteAlarm(Alarm alarm)
deleteAlarm in interface AlarmDAOpublic void saveMemberAlarms(java.lang.String member)
public void updateAlarm(Alarm alarm)
updateAlarm in interface AlarmDAOpublic void updateStatus(Status status)
updateStatus in interface AlarmDAOpublic java.util.Collection search(java.lang.String select_sql)
public java.util.Collection archiveSearch(java.lang.String select_sql)
archiveSearch in interface AlarmDAOpublic Building findBuilding(java.lang.String building)
findBuilding in interface AlarmDAOpublic void setConfAccessor(ConfigurationAccessor conf)
public void setSurveillanceAlarmId(java.lang.String surveillanceAlarmId)
public void setResponsiblePersonDAO(ResponsiblePersonDAO responsiblePersonDAO)
public java.lang.String[] getAllAlarmIDs()
public java.util.concurrent.ConcurrentHashMap<java.lang.String,Source> getSources()
public void setAlarmCache(ACSAlarmCacheImpl alarmCache)
public void setAlarmProcessor(AlarmMessageProcessorImpl processor)