org.eso.ias.dasu.subscriber

The input subscriber to send event to the listener

This subscriber, especially useful for testing, allows to programmatically submit inputs that will be immediately sent to the listener.

Attributes

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

Supertypes: class Object

trait Matchable

class Any
Known subtypes: class DirectInputSubscriber

class KafkaSubscriber

class Supervisor

A listener of inputs like the DASU

Supertypes: class Object

trait Matchable

class Any
Known subtypes: class Dasu

class DasuImpl

class DasuMock

class IasValueProcessor

class Supervisor

Read IASValues from the kafka queue and forward them to the listener for processing.

KafkaSubscriber delegates to KafkaIasiosConsumer and it is mostly a convenience class to use the java KafkaIasiosConsumer class from scala

Filtering by ID, passed in startSuscriber, is supported by delegating to the KafkaIasiosConsumer.

Companion: object
Supertypes: trait InputSubscriber

trait IasioListener

class Object

trait Matchable

class Any

KafkaSubscriber companion object