Mirrors_Framework/mosquitto
1
0
Fork 0
mirror of https://github.com/eclipse-mosquitto/mosquitto.git synced 2026-09-22 08:04:23 +08:00
Code Issues Packages Projects Releases Wiki Activity

set mqtt v5 callbacks in C++ wrapper of lib

Browse Source 
This caused "unused function" warnings

Signed-off-by: Kai Buschulte <kai.buschulte@cedalo.com>
This commit is contained in:
Kai Buschulte
2022-08-29 11:21:50 +00:00
parent 1d230bd255
commit c646172c05
1 changed files with 21 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/cpp/mosquittopp.cpp
+21 -16
View File
@@ -257,18 +257,30 @@ mosqpp_EXPORT int subscribe_callback(
will, tls);
}
namespace {
void mosquitto_callbacks_set(struct mosquitto *mosq) {
mosquitto_pre_connect_callback_set(mosq, on_pre_connect_wrapper);
mosquitto_connect_callback_set(mosq, on_connect_wrapper);
mosquitto_connect_with_flags_callback_set(mosq, on_connect_with_flags_wrapper);
mosquitto_connect_v5_callback_set(mosq, on_connect_v5_wrapper);
mosquitto_disconnect_callback_set(mosq, on_disconnect_wrapper);
mosquitto_disconnect_v5_callback_set(mosq, on_disconnect_v5_wrapper);
mosquitto_publish_callback_set(mosq, on_publish_wrapper);
mosquitto_publish_v5_callback_set(mosq, on_publish_v5_wrapper);
mosquitto_message_callback_set(mosq, on_message_wrapper);
mosquitto_message_v5_callback_set(mosq, on_message_v5_wrapper);
mosquitto_subscribe_callback_set(mosq, on_subscribe_wrapper);
mosquitto_subscribe_v5_callback_set(mosq, on_subscribe_v5_wrapper);
mosquitto_unsubscribe_callback_set(mosq, on_unsubscribe_wrapper);
mosquitto_unsubscribe_v5_callback_set(mosq, on_unsubscribe_v5_wrapper);
mosquitto_log_callback_set(mosq, on_log_wrapper);
}
}
mosquittopp::mosquittopp(const char *id, bool clean_session)
{
m_mosq = mosquitto_new(id, clean_session, this);
mosquitto_connect_callback_set(m_mosq, on_connect_wrapper);
mosquitto_connect_with_flags_callback_set(m_mosq, on_connect_with_flags_wrapper);
mosquitto_disconnect_callback_set(m_mosq, on_disconnect_wrapper);
mosquitto_publish_callback_set(m_mosq, on_publish_wrapper);
mosquitto_message_callback_set(m_mosq, on_message_wrapper);
mosquitto_subscribe_callback_set(m_mosq, on_subscribe_wrapper);
mosquitto_unsubscribe_callback_set(m_mosq, on_unsubscribe_wrapper);
mosquitto_log_callback_set(m_mosq, on_log_wrapper);
mosquitto_callbacks_set(m_mosq);
}
mosquittopp::~mosquittopp()
@@ -281,14 +293,7 @@ int mosquittopp::reinitialise(const char *id, bool clean_session)
int rc;
rc = mosquitto_reinitialise(m_mosq, id, clean_session, this);
if(rc == MOSQ_ERR_SUCCESS){
mosquitto_connect_callback_set(m_mosq, on_connect_wrapper);
mosquitto_connect_with_flags_callback_set(m_mosq, on_connect_with_flags_wrapper);
mosquitto_disconnect_callback_set(m_mosq, on_disconnect_wrapper);
mosquitto_publish_callback_set(m_mosq, on_publish_wrapper);
mosquitto_message_callback_set(m_mosq, on_message_wrapper);
mosquitto_subscribe_callback_set(m_mosq, on_subscribe_wrapper);
mosquitto_unsubscribe_callback_set(m_mosq, on_unsubscribe_wrapper);
mosquitto_log_callback_set(m_mosq, on_log_wrapper);
mosquitto_callbacks_set(m_mosq);
}
return rc;
}