Package org.yamcs.alarms

Class AbstractAlarmServer<S,T>

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.alarms.AbstractAlarmServer<S,T>

All Implemented Interfaces:

com.google.common.util.concurrent.Service

Direct Known Subclasses:

AbstractAlarmMirrorServer, AlarmServer

public abstract class AbstractAlarmServer<S,T>
extends com.google.common.util.concurrent.AbstractService

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Field Summary

Fields

Modifier and Type	Field	Description
protected Map<S,ActiveAlarm<T>>	activeAlarms
protected CopyOnWriteArrayList<AlarmListener<T>>	alarmListeners
protected final Log	log
protected final TimeService	timeService
protected final String	yamcsInstance

Constructor Summary

Constructors

Constructor	Description
AbstractAlarmServer(String yamcsInstance)

Method Summary

Modifier and Type	Method	Description
protected abstract void	addActiveAlarmFromTuple(Mdb mdb, Tuple t, Map<S,ActiveAlarm<T>> alarms)
Map<S,ActiveAlarm<T>>	addAlarmListener(AlarmListener<T> listener)	Register for alarm notices
protected abstract String	alarmTableName()
Map<S,ActiveAlarm<T>>	getActiveAlarms()	Returns the current set of active alarms
protected abstract String	getColNameLastEvent()
protected abstract String	getColNameSeverityIncreased()
protected Object	getLock(S alarmId)
protected abstract S	getSubject(T value)
protected void	loadAlarmsFromDb(double numDays, Map<S,ActiveAlarm<T>> alarms)
void	removeAlarmListener(AlarmListener<T> listener)

Methods inherited from class com.google.common.util.concurrent.AbstractService

addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, doCancelStart, doStart, doStop, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

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

Field Details

log

protected final Log log

yamcsInstance

protected final String yamcsInstance

timeService

protected final TimeService timeService

activeAlarms

protected Map<S,ActiveAlarm<T>> activeAlarms

alarmListeners

protected CopyOnWriteArrayList<AlarmListener<T>> alarmListeners

Constructor Details

AbstractAlarmServer

public AbstractAlarmServer(String yamcsInstance)

Method Details

getActiveAlarms

public Map<S,ActiveAlarm<T>> getActiveAlarms()

Returns the current set of active alarms

addAlarmListener

public Map<S,ActiveAlarm<T>> addAlarmListener(AlarmListener<T> listener)

Register for alarm notices

Returns:

the current set of active alarms

removeAlarmListener

public void removeAlarmListener(AlarmListener<T> listener)

loadAlarmsFromDb

protected void loadAlarmsFromDb(double numDays,
 Map<S,ActiveAlarm<T>> alarms)

getLock

protected Object getLock(S alarmId)

addActiveAlarmFromTuple

protected abstract void addActiveAlarmFromTuple(Mdb mdb,
 Tuple t,
 Map<S,ActiveAlarm<T>> alarms)

getSubject

protected abstract S getSubject(T value)

alarmTableName

protected abstract String alarmTableName()

getColNameLastEvent

protected abstract String getColNameLastEvent()

getColNameSeverityIncreased

protected abstract String getColNameSeverityIncreased()