root
API
Generated with
root/org.eso.ias/org.eso.ias.monitor/org.eso.ias.monitor.alarmpublisher/BsdbAlarmPublisherImpl

BsdbAlarmPublisherImpl

org.eso.ias.monitor.alarmpublisher.BsdbAlarmPublisherImpl
class BsdbAlarmPublisherImpl(val stringProducer: SimpleStringProducer) extends MonitorAlarmPublisher

Sends alarms to the BSDB by delegating to the KafkaIasiosProducer

Value parameters

stringProducer

The shared kafka string producer

Attributes

Graph
Supertypes
class Object
trait Matchable
class Any

Members list

Value members

Concrete methods

override def flush(): Unit

Flush the values to force immediate sending

Flush the values to force immediate sending

Attributes

Definition Classes
override def push(iasios: Array[IASValue[_]]): Unit

Send the passed values to the BSDB

Send the passed values to the BSDB

Attributes

Definition Classes
override def setUp(): Unit

Preparae the publisher to send data

Preparae the publisher to send data

Attributes

Definition Classes
override def tearDown(): Unit

Closes the publisher: no alarms will be sent afetr closing

Closes the publisher: no alarms will be sent afetr closing

Attributes

Definition Classes

Concrete fields

val stringProducer: SimpleStringProducer
Generated with