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=dripline_config(), const scarab::authentication &a_auth=scarab::authentication(), const bool a_make_connection=true)	core
core(const core &a_orig)=default	core
core(core &&a_orig)=default	core
do_cancellation(int a_code)	relayer	private
do_send(message_ptr_t a_message, const std::string &a_exchange, bool a_expect_reply, amqp_channel_ptr a_channel=amqp_channel_ptr()) const	core	protected
execute_relayer()	relayer
f_queue	relayer	mutableprivate
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)	core	static
mar_ptr typedef	relayer	private
open_channel() const	core	protected
operator=(const relayer &)=delete	relayer
operator=(relayer &&)	relayer
dripline::core::operator=(const core &a_orig)=default	core
dripline::core::operator=(core &&a_orig)=default	core
post_listen_status enum name	core
relayer(const scarab::param_node &a_config, const scarab::authentication &a_auth)	relayer
relayer(const relayer &)=delete	relayer
relayer(relayer &&)=default	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, amqp_channel_ptr a_channel=amqp_channel_ptr()) const	core	virtual
send(reply_ptr_t a_reply, amqp_channel_ptr a_channel=amqp_channel_ptr()) const	core	virtual
send(alert_ptr_t a_alert, amqp_channel_ptr a_channel=amqp_channel_ptr()) 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_accessible(unsigned, max_connection_attempts)	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, core::post_listen_status &a_status, int a_timeout_ms=0)	relayer
wait_for_send_pkg_ptr typedef	relayer
~core()=default	core	virtual
~relayer()=default	relayer	virtual