Disclaimer: current state of the driver is experimental, and although APIs are not likely to change drastically, some adjustments may be made in the future. Please also keep in mind that this driver is not backed by Yandex-scale production usage.

🐙 userver provides access to RabbitMQ servers via components::RabbitMQ. The uRabbitMQ driver is asynchronous, it suspends current coroutine for carrying out network I/O.

Features

Publishing messages;
Consuming messages;
Creating Exchanges, Queues and Bindings;
Transport level security;
Connections pooling;
End-to-end logging for messages in publish->consume chain.

More information

For configuration see components::RabbitMQ
For cluster operations see urabbitmq::Client, urabbitmq::AdminChannel, urabbitmq::Channel, urabbitmq::ReliableChannel
For consumers support see urabbitmq::ConsumerBase and urabbitmq::ConsumerComponentBase

⇦ gRPC | Dynamic config ⇨