root
API
Generated with
root/org.eso.ias/org.eso.ias.heartbeat/org.eso.ias.heartbeat.publisher/HbKafkaProducer

HbKafkaProducer

org.eso.ias.heartbeat.publisher.HbKafkaProducer
class HbKafkaProducer(val kafkaProducer: SimpleStringProducer, id: String, serializer: HbMsgSerializer) extends HbProducer

Publish the HB in a kafka topic with a kafka

Value parameters

kafkaProducer

The kafka string producer to publish heartbeats

serializer

the serializer to transform HBs into strings

Attributes

Graph
Supertypes
class HbProducer
class Object
trait Matchable
class Any

Members list

Value members

Concrete methods

override def init(): Unit

Initialize: nothing to do in this implementation

Initialize: nothing to do in this implementation

Attributes

Definition Classes
override def push(hbAsString: String): Unit

Push the string

Push the string

Attributes

Definition Classes
override def shutdown(): Unit

Shutdown: nothing to do in this implementation

Shutdown: nothing to do in this implementation

Attributes

Definition Classes

Inherited methods

def send(hb: Heartbeat, status: HeartbeatStatus, additionalProperties: Map[String, String]): Unit

Publish the HB message with the passed time stamp

Publish the HB message with the passed time stamp

Value parameters

hb

the heartbeat

status

the status of the tool

Attributes

Inherited from:
HbProducer

Concrete fields

val closed: AtomicBoolean
val initialized: AtomicBoolean
val kafkaProducer: SimpleStringProducer
Generated with