Package com.reallifedeveloper.common.infrastructure.messaging

Class RabbitMQNotificationPublisher

java.lang.Object

com.reallifedeveloper.common.infrastructure.messaging.RabbitMQNotificationPublisher

All Implemented Interfaces:

NotificationPublisher

public final class RabbitMQNotificationPublisher
extends Object
implements NotificationPublisher

An implementation of the NotificationPublisher interface that uses RabbiMQ.

Author:

RealLifeDeveloper

Constructor Summary

Constructors

Constructor	Description
RabbitMQNotificationPublisher(com.rabbitmq.client.ConnectionFactory connectionFactory, ObjectSerializer<String> objectSerializer)	Creates a new RabbitMQNotificationPublisher that connects to RabbitMQ using the given ConnectionFactory.

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

RabbitMQNotificationPublisher

public RabbitMQNotificationPublisher(com.rabbitmq.client.ConnectionFactory connectionFactory,
 ObjectSerializer<String> objectSerializer)

Creates a new RabbitMQNotificationPublisher that connects to RabbitMQ using the given ConnectionFactory.

Parameters:

connectionFactory - the ConnectionFactory to use to create connections to RabbitMQ

objectSerializer - the ObjectSerializer to use to serialize notifications

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