MonitorAlarmsProducer

org.eso.ias.monitor.MonitorAlarmsProducer
See theMonitorAlarmsProducer companion object
class MonitorAlarmsProducer(val publisher: MonitorAlarmPublisher, val refreshRate: Long, id: String) extends Runnable

The alarms producer that periodically publishes the alarms defined in MonitorAlarm.

In this version the alarms are sent to the Kafka core topic as org.eso.ias.types.IASValue.

TODO: send the alarms directly to the webserver so that it works even if kafka is down

Value parameters

id

The identifier of the Monitor

publisher

the publisher of alarms

refreshRate

The refresh rate (seconds) to periodically send alarms

Attributes

Companion
object
Graph
Supertypes
trait Runnable
class Object
trait Matchable
class Any

Members list

Value members

Concrete methods

def buildIasValue(id: String, value: Alarm, prop: String): IASValue[_]

Build the IASValue to send to the BSDB

Build the IASValue to send to the BSDB

Value parameters

id

The identifier of the alarm

prop

property with the list of faulty IDs

value

the alarm state and priority

Attributes

Returns

the IASValue to send to the BSDB

override def run(): Unit

Periodically sends the alarms defined in org.eso.ias.monitor.MonitorAlarm

Periodically sends the alarms defined in org.eso.ias.monitor.MonitorAlarm

Attributes

Definition Classes
Runnable
def shutdown(): Unit

Stops sending alarms and frees resources

Stops sending alarms and frees resources

Attributes

def start(): Unit

Start sending alarms

Start sending alarms

Attributes

Concrete fields

The identifier of the Monitor tool

The identifier of the Monitor tool

Attributes

val refreshRate: Long