RabbitMQGroupsEventsConsumer

class RabbitMQGroupsEventsConsumer(groupsRepository: GroupsRepository, configuration: RabbitMQ.Configuration, dispatcher: CoroutineDispatcher = Dispatchers.IO) : RabbitMQMessageHandler

RabbitMQ groups events consumer adapter.

Constructors

constructor(groupsRepository: GroupsRepository, 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.