relayer Member List

This is the complete list of members for relayer, 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_cancellation(int a_code)	relayer	private
do_send(message_ptr_t a_message, const std::string &a_exchange, bool a_expect_reply) const	core	protected
execute_relayer()	relayer
f_queue	relayer	mutableprivate
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
mar_ptr typedef	relayer	private
open_channel() const	core	protected
operator=(const core &a_orig)	core
operator=(core &&a_orig)	core
relayer(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="")	relayer
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_async(request_ptr_t a_request) const	relayer
send_async(alert_ptr_t a_alert) const	relayer
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(receiver, msg_receiver)	relayer	private
dripline::core::snake_case_mv_referrable(std::string, address)	core
dripline::core::snake_case_mv_referrable(std::string, username)	core
dripline::core::snake_case_mv_referrable(std::string, password)	core
dripline::core::snake_case_mv_referrable(std::string, requests_exchange)	core
dripline::core::snake_case_mv_referrable(std::string, alerts_exchange)	core
dripline::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
wait_for_reply(const wait_for_send_pkg_ptr a_receive_reply, int a_timeout_ms=0)	relayer
wait_for_reply(const wait_for_send_pkg_ptr a_receive_reply, bool &a_chan_valid, int a_timeout_ms=0)	relayer
wait_for_send_pkg_ptr typedef	relayer
~core()	core	virtual
~relayer()	relayer	virtual