Package ch.admin.bit.jeap.reaction.observer.events.producer

Class KafkaEventProducer

java.lang.Object

ch.admin.bit.jeap.reaction.observer.events.producer.KafkaEventProducer

All Implemented Interfaces:

ReactionIdentifiedListener

public class KafkaEventProducer
extends Object
implements ReactionIdentifiedListener

Constructor Summary

Constructors

Constructor	Description
KafkaEventProducer(ch.admin.bit.jeap.messaging.kafka.properties.KafkaProperties kafkaProperties, ReactionObserverKafkaConfigProperties config, org.springframework.kafka.core.KafkaTemplate<ch.admin.bit.jeap.messaging.avro.AvroMessageKey,ch.admin.bit.jeap.messaging.avro.AvroMessage> kafkaTemplate)

Method Summary

Modifier and Type	Method	Description
void	init()
void	onReactionIdentified(Reaction reaction)
void	sendReactionObservedEvent(Map<String,AtomicInteger> countByReactionId, Instant from, Instant to)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KafkaEventProducer

public KafkaEventProducer(ch.admin.bit.jeap.messaging.kafka.properties.KafkaProperties kafkaProperties,
 ReactionObserverKafkaConfigProperties config,
 org.springframework.kafka.core.KafkaTemplate<ch.admin.bit.jeap.messaging.avro.AvroMessageKey,ch.admin.bit.jeap.messaging.avro.AvroMessage> kafkaTemplate)

Method Details

init

@PostConstruct
public void init()

onReactionIdentified

public void onReactionIdentified(Reaction reaction)

Specified by:

onReactionIdentified in interface ReactionIdentifiedListener

sendReactionObservedEvent

public void sendReactionObservedEvent(Map<String,AtomicInteger> countByReactionId,
 Instant from,
 Instant to)