after_connect_callback_call() | mqtt_client | |
after_connect_callback_set(mqtt_simple_callback_t) | mqtt_client | |
after_connect_callbacks | mqtt_client | private |
before_disconnect_callback_call() | mqtt_client | |
before_disconnect_callback_set(mqtt_simple_callback_t) | mqtt_client | |
before_disconnect_callbacks | mqtt_client | private |
connect() | mqtt_client | private |
connected_to_broker | mqtt_client | private |
count_topics(const std::string &prefix_pattern) | mqtt_client | |
current_state | mqtt_client | private |
delayed_event_sender | mqtt_client | |
disconnect() | mqtt_client | |
event(const int incoming_event) | mqtt_client | |
event_counter | mqtt_client | |
event_sender | mqtt_client | |
file_descriptor() | mqtt_client | |
get_client_id() const | mqtt_client | |
hostname | mqtt_client | private |
is_connected_to_broker() const | mqtt_client | |
max_reconnect_backoff | mqtt_client | private |
mqtt_cafile | mqtt_client | private |
mqtt_certfile | mqtt_client | private |
mqtt_client(const std::string &hostname, const uint32_t port, const std::string &client_id, const std::string &cafile, const std::string &certfile, const std::string &keyfile, std::function< int(const int, void *)> event_sender, std::function< void(const int, const unsigned long)> delayed_event_sender, std::function< int(const int, void *)> event_counter) | mqtt_client | |
mqtt_client_fsm_connected | mqtt_client | friend |
mqtt_client_fsm_connecting | mqtt_client | friend |
mqtt_client_fsm_disconnected | mqtt_client | friend |
mqtt_client_id | mqtt_client | private |
mqtt_client_library_instance | mqtt_client | private |
mqtt_keyfile | mqtt_client | private |
next_reconnect_backoff | mqtt_client | private |
on_connect(int return_code) | mqtt_client | |
on_connect_callback_set(mqtt_connection_callback_t) | mqtt_client | |
on_connect_callbacks | mqtt_client | private |
on_disconnect(int return_code) | mqtt_client | |
on_disconnect_callback_set(mqtt_connection_callback_t) | mqtt_client | |
on_disconnect_callbacks | mqtt_client | private |
on_message(const std::string &topic, const std::string &message, size_t message_length, int message_qos, bool message_retain) | mqtt_client | |
poll() | mqtt_client | |
port | mqtt_client | private |
publish(const std::string &topic, const std::string &message, size_t message_length, bool retain) | mqtt_client | |
publish_messages_waiting() | mqtt_client | private |
publish_to_broker(bool flushing=false) | mqtt_client | private |
publishing_queue | mqtt_client | private |
resubscribe() | mqtt_client | |
retained_topics | mqtt_client | private |
send_delayed_event(const int outgoing_event, std::chrono::milliseconds delay_time) | mqtt_client | private |
send_event(const int outgoing_event, void *procdata) | mqtt_client | private |
setup() | mqtt_client | |
socket_file_descriptor | mqtt_client | private |
subscribe(const std::string &topic, const callback_info &callback) | mqtt_client | |
subscribe_to_topic() | mqtt_client | private |
subscription_callbacks | mqtt_client | private |
subscription_messages_waiting() | mqtt_client | private |
subscription_queue | mqtt_client | private |
teardown() | mqtt_client | |
transition(mqtt_client_fsm &new_state) | mqtt_client | private |
unretain(const std::string &prefix_pattern) | mqtt_client | |
unretain_by_regex(const std::string ®ex) | mqtt_client | |
unsubscribe(const std::string &topic, const callback_info &callback) | mqtt_client | |
unsubscribe_from_topic() | mqtt_client | private |
unsubscription_messages_waiting() | mqtt_client | private |
unsubscription_queue | mqtt_client | private |