Package com.reallifedeveloper.common.infrastructure.messaging

Class KafkaNotificationPublisher

java.lang.Object

com.reallifedeveloper.common.infrastructure.messaging.KafkaNotificationPublisher

All Implemented Interfaces:

NotificationPublisher

public final class KafkaNotificationPublisher
extends Object
implements NotificationPublisher

An implementation of the NotificationPublisher interface which uses Apache Kafka.

Author:

RealLifeDeveloper

Constructor Summary

Constructors

Constructor	Description
KafkaNotificationPublisher(org.springframework.kafka.core.KafkaTemplate<String,String> kafkaTemplate, ObjectSerializer<String> objectSerializer)	Creates a new KafkaNotificationPublisher which uses the given ObjectSerializer to serialize notifications, and the given KafkaTemplate to send them to Kafka.

Method Summary

Modifier and Type	Method	Description
void	publish(List<Notification> notifications, String publicationChannel)	Publishes a number of notifications to the given publication channel.

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaNotificationPublisher

public KafkaNotificationPublisher(org.springframework.kafka.core.KafkaTemplate<String,String> kafkaTemplate,
 ObjectSerializer<String> objectSerializer)

Creates a new KafkaNotificationPublisher which uses the given ObjectSerializer to serialize notifications, and the given KafkaTemplate to send them to Kafka.

Parameters:

kafkaTemplate - the KafkaTemplate to use

objectSerializer - the ObjectSerializer to use

Method Details

publish

public void publish(List<Notification> notifications,
 String publicationChannel)
             throws IOException

Description copied from interface: NotificationPublisher

Publishes a number of notifications to the given publication channel.

Specified by:

publish in interface NotificationPublisher

Parameters:

notifications - a list of Notifications to publish

publicationChannel - the name of the publication channel

Throws:

IOException - if publishing failed