Class KafkaEventProducer

java.lang.Object

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

All Implemented Interfaces:

ch.admin.bit.jeap.reaction.observer.core.domain.listener.ReactionIdentifiedListener

public class KafkaEventProducer
extends Object
implements ch.admin.bit.jeap.reaction.observer.core.domain.listener.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(ch.admin.bit.jeap.reaction.observer.core.domain.model.Reaction reaction)
void	sendReactionObservedEvent(Map<String, AtomicInteger> countByReactionId, Instant from, Instant to)

Methods inherited from class 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(ch.admin.bit.jeap.reaction.observer.core.domain.model.Reaction reaction)

Specified by:

onReactionIdentified in interface ch.admin.bit.jeap.reaction.observer.core.domain.listener.ReactionIdentifiedListener

sendReactionObservedEvent

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