#include <userver/urabbitmq/admin_channel.hpp>
Administrative interface for the broker. You may use this class to setup your exchanges/queues/bindings. You may as well use Client
itself instead.
You are not expected to store this class for a long time, because it takes a connection from the underlying connections pool.
Usually retrieved from Client
Definition at line 26 of file admin_channel.hpp.
Public Member Functions | |
AdminChannel (ConnectionPtr &&channel) | |
AdminChannel (AdminChannel &&other) noexcept | |
void | DeclareExchange (const Exchange &exchange, Exchange::Type type, utils::Flags< Exchange::Flags > flags, engine::Deadline deadline) override |
Declare an exchange. | |
void | DeclareExchange (const Exchange &exchange, Exchange::Type type, engine::Deadline deadline) override |
overload of DeclareExchange | |
void | DeclareExchange (const Exchange &exchange, engine::Deadline deadline) override |
overload of DeclareExchange | |
void | DeclareQueue (const Queue &queue, utils::Flags< Queue::Flags > flags, engine::Deadline deadline) override |
Declare a queue. | |
void | DeclareQueue (const Queue &queue, engine::Deadline deadline) override |
overload of DeclareQueue | |
void | BindQueue (const Exchange &exchange, const Queue &queue, const std::string &routing_key, engine::Deadline deadline) override |
Bind a queue to an exchange. | |
void | RemoveExchange (const Exchange &exchange, engine::Deadline deadline) override |
Remove an exchange. | |
void | RemoveQueue (const Queue &queue, engine::Deadline deadline) override |
Remove a queue. | |
|
overridevirtual |
Bind a queue to an exchange.
exchange | the source exchange |
queue | the target queue |
routing_key | the routing key |
deadline | execution deadline |
Implements urabbitmq::IAdminInterface.
|
inlineoverridevirtual |
overload of DeclareExchange
Implements urabbitmq::IAdminInterface.
Definition at line 42 of file admin_channel.hpp.
|
inlineoverridevirtual |
overload of DeclareExchange
Implements urabbitmq::IAdminInterface.
Definition at line 37 of file admin_channel.hpp.
|
overridevirtual |
Declare an exchange.
exchange | name of the exchange |
type | exchange type |
flags | exchange flags |
deadline | execution deadline |
Implements urabbitmq::IAdminInterface.
|
inlineoverridevirtual |
overload of DeclareQueue
Implements urabbitmq::IAdminInterface.
Definition at line 50 of file admin_channel.hpp.
|
overridevirtual |
Declare a queue.
queue | name of the queue |
flags | queue flags |
deadline | execution deadline |
Implements urabbitmq::IAdminInterface.
|
overridevirtual |
Remove an exchange.
exchange | name of the exchange to remove |
deadline | execution deadline |
Implements urabbitmq::IAdminInterface.
|
overridevirtual |
Remove a queue.
queue | name of the queue to remove |
deadline | execution deadline |
Implements urabbitmq::IAdminInterface.