root
API
Generated with
root/org.eso.ias/org.eso.ias.heartbeat/org.eso.ias.heartbeat.consumer

org.eso.ias.heartbeat.consumer

package org.eso.ias.heartbeat.consumer

Members list

Type members

Classlikes

class HbKafkaConsumer(brokers: String, val consumerId: String) extends StringsConsumer, Runnable

The HbKafkaConsumer gets HBs from the hb kakfa topic and notifies the registered listeners

The HbKafkaConsumer gets HBs from the hb kakfa topic and notifies the registered listeners

HbKafkaConsumer is the listener of the KafkaStringsConsumer and forward the events to registered listeners. Events received from the topic are stored in a temporary buffer and sent to the listeners asynchronously

Value parameters

brokers

Kafka brokers to connect to

consumerId

The id for the consumer

Attributes

Companion
object
Supertypes
trait Runnable
trait StringsConsumer
class Object
trait Matchable
class Any
object HbKafkaConsumer

Companion object

Companion object

Attributes

Companion
class
Supertypes
class Object
trait Matchable
class Any
Self type
trait HbListener

The trait for the listener of HB consumed from the kafka topic

The trait for the listener of HB consumed from the kafka topic

Attributes

Supertypes
class Object
trait Matchable
class Any
Known subtypes
class HbsCollector
class HbMonitor
case class HbMsg(hb: Heartbeat, status: HeartbeatStatus, props: Map[String, String], timestamp: Long)

The message read from the kafka topic

The message read from the kafka topic

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all
Generated with