RabbitMQNotificationsConsumer

class RabbitMQNotificationsConsumer(notificationPublisher: NotificationPublisher, configuration: RabbitMQ.Configuration, dispatcher: CoroutineDispatcher = Dispatchers.IO) : RabbitMQMessageHandler

RabbitMQ notification commands consumer adapter.

Constructors

constructor(notificationPublisher: NotificationPublisher, configuration: RabbitMQ.Configuration, dispatcher: CoroutineDispatcher = Dispatchers.IO)

open override fun close()

Set up the RabbitMQ connection and declare the exchange and queue. Here side effects occur.