try reconnect even on initial no connection established
This commit is contained in:
@@ -380,9 +380,8 @@ MqttHandler::MqttHandler(UserInfo* userInfo, BusHandler* busHandler, MessageMap*
|
|||||||
#else
|
#else
|
||||||
if (mosquitto_connect(m_mosquitto, g_host, g_port, 60, true) != MOSQ_ERR_SUCCESS) {
|
if (mosquitto_connect(m_mosquitto, g_host, g_port, 60, true) != MOSQ_ERR_SUCCESS) {
|
||||||
#endif
|
#endif
|
||||||
logOtherError("mqtt", "unable to connect");
|
m_connected = false;
|
||||||
mosquitto_destroy(m_mosquitto);
|
logOtherNotice("mqtt", "unable to connect - retry...");
|
||||||
m_mosquitto = NULL;
|
|
||||||
} else {
|
} else {
|
||||||
m_connected = true; // assume success until connect_callback says otherwise
|
m_connected = true; // assume success until connect_callback says otherwise
|
||||||
logOtherDebug("mqtt", "connection requested");
|
logOtherDebug("mqtt", "connection requested");
|
||||||
|
|||||||
Reference in New Issue
Block a user