InputSubscriber

org.eso.ias.dasu.subscriber.InputSubscriber

InputSubscriber get events from different sources and send them to the InputsListener

Attributes

Graph
Supertypes
class Object
trait Matchable
class Any
Known subtypes

Members list

Value members

Abstract methods

def cleanUpSubscriber(): Try[Unit]

CleanUp and release the resources

CleanUp and release the resources

Attributes

def initializeSubscriber(): Try[Unit]

Initialize the subscriber

Initialize the subscriber

The get events, start() must be called

Attributes

def startSubscriber(listener: InputsListener, acceptedInputs: Set[String]): Try[Unit]

Start to get events and forward them to the listener.

Start to get events and forward them to the listener.

IASIOs whose ID is not in the acceptedInputs set are discarded.

Value parameters

acceptedInputs

the IDs of the inputs accepted by the listener

listener

the listener of events

Attributes