ValueListener

org.eso.ias.sink.ValueListener
See theValueListener companion object
abstract class ValueListener(val id: String)

The listener of IasValues to be processed

Value parameters

id

The identifier to distinguish between many listeners in the same processor Mainly used for logging messages

Attributes

Companion
object
Graph
Supertypes
class Object
trait Matchable
class Any
Known subtypes

Members list

Value members

Concrete methods

def isBroken: Boolean

Attributes

Returns

true if the processor is broken; false otherwise

def markAsBroken(): Unit

Mark the listener as broken so the it is not run anymore

Mark the listener as broken so the it is not run anymore

One possibe use case is when the processor detects that the thread is too slow and decide not to run it again

Attributes

final def processIasValues(iasValues: List[IASValue[_]]): String

A new set of IasValues has been received from the BSDB and needs to be processed

A new set of IasValues has been received from the BSDB and needs to be processed

Value parameters

iasValues

the values read from the BSDB

Attributes

final def setUp(iasDao: IasDao, iasValues: Map[String, IasioDao]): String

Initialization

Initialization

Value parameters

iasDao

The configuration of the IAS read from the CDB

iasValues

The configuration of the IASIOs read from the CDB

Attributes

final def tearDown(): String

Concrete fields

val closed: AtomicBoolean

The listener has been closed

The listener has been closed

Attributes

val id: String
val initialized: AtomicBoolean

The listener has been initialized

The listener has been initialized

Attributes