|
| ~Client () |
| Client destructor.
|
|
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.
|
|
AdminChannel | GetAdminChannel (engine::Deadline deadline) |
| Get an administrative interface for the broker.
|
|
void | Publish (const Exchange &exchange, const std::string &routing_key, const std::string &message, MessageType type, engine::Deadline deadline) override |
| Publish a message to an exchange.
|
|
void | Publish (const Exchange &exchange, const std::string &routing_key, const std::string &message, engine::Deadline deadline) override |
| overload of Publish
|
|
Channel | GetChannel (engine::Deadline deadline) |
| Get a publisher interface for the broker.
|
|
void | PublishReliable (const Exchange &exchange, const std::string &routing_key, const std::string &message, MessageType type, engine::Deadline deadline) override |
| Publish a message to an exchange and await confirmation from the broker.
|
|
void | PublishReliable (const Exchange &exchange, const std::string &routing_key, const std::string &message, engine::Deadline deadline) override |
| overload of PublishReliable
|
|
ReliableChannel | GetReliableChannel (engine::Deadline deadline) |
| Get a reliable publisher interface for the broker (publisher-confirms)
|
|
void | WriteStatistics (utils::statistics::Writer &writer) const |
| Write cluster statistics.
|
|