![]() |
Dripline-Cpp
v2.4.2
Dripline Implementation in C++
|
This is the complete list of members for core, including all inherited members.
bind_key(amqp_channel_ptr a_channel, const std::string &a_exchange, const std::string &a_queue_name, const std::string &a_routing_key) | core | protectedstatic |
core(const scarab::param_node &a_config=scarab::param_node(), const std::string &a_broker_address="", unsigned a_port=0, const std::string &a_auth_file="", const bool a_make_connection=true) | core | |
core(const bool a_make_connection, const scarab::param_node &a_config=scarab::param_node()) | core | |
core(const core &a_orig) | core | |
core(core &&a_orig) | core | |
do_send(message_ptr_t a_message, const std::string &a_exchange, bool a_expect_reply) const | core | protected |
listen_for_message(amqp_envelope_ptr &a_envelope, amqp_channel_ptr a_channel, const std::string &a_consumer_tag, int a_timeout_ms=0, bool a_do_ack=true) | core | static |
open_channel() const | core | protected |
operator=(const core &a_orig) | core | |
operator=(core &&a_orig) | core | |
receiver class | core | friend |
remove_queue(amqp_channel_ptr a_channel, const std::string &a_queue_name) | core | protectedstatic |
s_offline | core | static |
send(request_ptr_t a_request) const | core | virtual |
send(reply_ptr_t a_reply) const | core | virtual |
send(alert_ptr_t a_alert) const | core | virtual |
send_noreply(message_ptr_t a_message, const std::string &a_exchange) const | core | protected |
send_withreply(message_ptr_t a_message, std::string &a_reply_consumer_tag, const std::string &a_exchange) const | core | protected |
setup_exchange(amqp_channel_ptr a_channel, const std::string &a_exchange) | core | protectedstatic |
setup_queue(amqp_channel_ptr a_channel, const std::string &a_queue_name) | core | protectedstatic |
snake_case_mv_accessible(unsigned, port) | core | |
snake_case_mv_accessible(unsigned, max_payload_size) | core | |
snake_case_mv_accessible(bool, make_connection) | core | |
snake_case_mv_referrable(std::string, address) | core | |
snake_case_mv_referrable(std::string, username) | core | |
snake_case_mv_referrable(std::string, password) | core | |
snake_case_mv_referrable(std::string, requests_exchange) | core | |
snake_case_mv_referrable(std::string, alerts_exchange) | core | |
snake_case_mv_referrable(std::string, heartbeat_routing_key) | core | |
start_consuming(amqp_channel_ptr a_channel, const std::string &a_queue_name) | core | protectedstatic |
stop_consuming(amqp_channel_ptr a_channel, std::string &a_consumer_tag) | core | protectedstatic |
~core() | core | virtual |