cern.laser.business.pojo

Class AlarmMessageProcessorImpl

java.lang.Object

cern.laser.business.pojo.AlarmMessageProcessorImpl

public class AlarmMessageProcessorImpl
extends java.lang.Object

CERN documentation is missing unfortunately... Below you can find ACS documentation of the changes done on top of the CERN class.

The AlarmMessageProcessorImpl checks the timestamp of the alarms it receives from the NC and publishes a core alarm (LaserCoreFaultState.LaserCoreFaultCodes.ALARMS_TOO_OLD) if the delay between the actual time and the timestamp exceeds the threshold (delayThreashold). The check is done in this class because this is the place where alarms from sources are checked.
To ensure that the alarm is set/cleared even if the alarms server does not process alarms, the check is done by the thread in createTimerTask().
This feature is tested in the alarmTest module.

Author:

acaproni

Field Summary

Fields

Modifier and Type	Field and Description
static long	alarmTimestampsCheckInterval The timestamp of alarms is checked every alarmTimestamsCheckInterval to reduce the risk to fill the alarm system publishing this alarm too often.
static long	delayThreashold If the timestamp of alarms and the actual time differ of more then delayThreashold then a core alarm is issued.

Constructor Summary

Constructors

Constructor and Description
AlarmMessageProcessorImpl(LaserComponent component, java.util.logging.Logger logger, StatsCalculator statsCalculator) Constructor

Method Summary

Modifier and Type	Method and Description
void	notifyReductionRelatives(Alarm alarm)
void	process(Message alarmMessage)
void	processChange(FaultState faultState, java.lang.String sourceName, java.lang.String sourceHostname, java.sql.Timestamp sourceTimestamp)
void	setAlarmCache(ACSAlarmCacheImpl alarmCache)
void	setSourceDAO(SourceDAO sourceDAO)
void	start() Start the periodic task
void	stop() Stop the periodic task
void	updateMultiplicityNode(Alarm alarm)
void	updateReductionStatus(Alarm alarm)

Methods inherited from class java.lang.Object

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

Field Detail

delayThreashold

public static final long delayThreashold

If the timestamp of alarms and the actual time differ of more then delayThreashold then a core alarm is issued.

alarmTimestampsCheckInterval

public static final long alarmTimestampsCheckInterval

The timestamp of alarms is checked every alarmTimestamsCheckInterval to reduce the risk to fill the alarm system publishing this alarm too often.

Constructor Detail

AlarmMessageProcessorImpl

public AlarmMessageProcessorImpl(LaserComponent component,
                                 java.util.logging.Logger logger,
                                 StatsCalculator statsCalculator)

Constructor

Parameters:

component - The LaserComponent

Method Detail

setSourceDAO

public void setSourceDAO(SourceDAO sourceDAO)

setAlarmCache

public void setAlarmCache(ACSAlarmCacheImpl alarmCache)

notifyReductionRelatives

public void notifyReductionRelatives(Alarm alarm)

process

public void process(Message alarmMessage)
             throws java.lang.Exception

Throws:

java.lang.Exception

processChange

public void processChange(FaultState faultState,
                          java.lang.String sourceName,
                          java.lang.String sourceHostname,
                          java.sql.Timestamp sourceTimestamp)
                   throws java.lang.Exception

Throws:

java.lang.Exception

updateMultiplicityNode

public void updateMultiplicityNode(Alarm alarm)

updateReductionStatus

public void updateReductionStatus(Alarm alarm)

start

public void start()

Start the periodic task

stop

public void stop()

Stop the periodic task