Dripline-Cpp  v2.10.11
Dripline Implementation in C++
core Member List

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)coreprotectedstatic
core(const scarab::param_node &a_config=dripline_config(), const scarab::authentication &a_auth=scarab::authentication(), const bool a_make_connection=true)core
core(const core &a_orig)=defaultcore
core(core &&a_orig)=defaultcore
do_send(message_ptr_t a_message, const std::string &a_exchange, bool a_expect_reply, amqp_channel_ptr a_channel=amqp_channel_ptr()) constcoreprotected
listen_for_message(amqp_envelope_ptr &a_envelope, post_listen_status &a_status, amqp_channel_ptr a_channel, const std::string &a_consumer_tag, int a_timeout_ms=0, bool a_do_ack=true)corestatic
open_channel() constcoreprotected
operator=(const core &a_orig)=defaultcore
operator=(core &&a_orig)=defaultcore
post_listen_status enum namecore
receiver classcorefriend
remove_queue(amqp_channel_ptr a_channel, const std::string &a_queue_name)coreprotectedstatic
s_offlinecorestatic
send(request_ptr_t a_request, amqp_channel_ptr a_channel=amqp_channel_ptr()) constcorevirtual
send(reply_ptr_t a_reply, amqp_channel_ptr a_channel=amqp_channel_ptr()) constcorevirtual
send(alert_ptr_t a_alert, amqp_channel_ptr a_channel=amqp_channel_ptr()) constcorevirtual
send_noreply(message_ptr_t a_message, const std::string &a_exchange) constcoreprotected
send_withreply(message_ptr_t a_message, std::string &a_reply_consumer_tag, const std::string &a_exchange) constcoreprotected
setup_exchange(amqp_channel_ptr a_channel, const std::string &a_exchange)coreprotectedstatic
setup_queue(amqp_channel_ptr a_channel, const std::string &a_queue_name)coreprotectedstatic
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_accessible(unsigned, max_connection_attempts)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)coreprotectedstatic
stop_consuming(amqp_channel_ptr a_channel, std::string &a_consumer_tag)coreprotectedstatic
~core()=defaultcorevirtual