Package-level declarations

Types

Link copied to clipboard
typealias QueueName = String

The name of a queue.

Link copied to clipboard
class RabbitMQ(configuration: RabbitMQ.Configuration) : ConnectionFactory<Connection>

A ConnectionFactory for a RabbitMQ message broker.

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

RabbitMQ groups events consumer adapter.

Link copied to clipboard

A message handler for RabbitMQ messages.

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

RabbitMQ notification commands consumer adapter.