// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- // vim: ts=8 sw=2 smarttab ft=cpp #pragma once #include #include #include #include "include/common_fwd.h" struct amqp_connection_info; namespace rgw::amqp { // the reply callback is expected to get an integer parameter // indicating the result, and not to return anything typedef std::function reply_callback_t; // initialize the amqp manager bool init(CephContext* cct); // shutdown the amqp manager void shutdown(); // key class for the connection list struct connection_id_t { std::string host; int port; std::string vhost; std::string exchange; bool ssl; connection_id_t() = default; connection_id_t(const amqp_connection_info& info, const std::string& _exchange); }; std::string to_string(const connection_id_t& id); // connect to an amqp endpoint bool connect(connection_id_t& conn_id, const std::string& url, const std::string& exchange, bool mandatory_delivery, bool verify_ssl, boost::optional ca_location); // publish a message over a connection that was already created int publish(const connection_id_t& conn_id, const std::string& topic, const std::string& message); // publish a message over a connection that was already created // and pass a callback that will be invoked (async) when broker confirms // receiving the message int publish_with_confirm(const connection_id_t& conn_id, const std::string& topic, const std::string& message, reply_callback_t cb); // convert the integer status returned from the "publish" function to a string std::string status_to_string(int s); // number of connections size_t get_connection_count(); // return the number of messages that were sent // to broker, but were not yet acked/nacked/timedout size_t get_inflight(); // running counter of successfully queued messages size_t get_queued(); // running counter of dequeued messages size_t get_dequeued(); // number of maximum allowed connections size_t get_max_connections(); // number of maximum allowed inflight messages size_t get_max_inflight(); // maximum number of messages in the queue size_t get_max_queue(); }