force get twin update after mqtt connection

This commit is contained in:
Oguz Bastemur 2019-02-28 16:10:13 -08:00
Родитель 374fc147a6
Коммит 623e5f62f2
2 изменённых файлов: 18 добавлений и 1 удалений

Просмотреть файл

@ -298,10 +298,19 @@ int iotc_connect(IOTContext ctx, const char* scope, const char* keyORcert,
errorCode += internal->mqttClient->subscribe("$iothub/twin/res/#"); // twin properties response
errorCode += internal->mqttClient->subscribe("$iothub/methods/POST/#");
if (errorCode < 3)
if (errorCode < 3) {
IOTC_LOG(F("ERROR: mqttClient couldn't subscribe to twin/methods etc. error code sum => %d"), errorCode);
}
connectionStatusCallback(IOTC_CONNECTION_OK, (IOTContextInternal*)ctx);
iotc_do_work(internal);
const char* twin_topic = "$iothub/twin/GET/?$rid=0";
internal->messageId++; // next rid=1
if (mqtt_publish(internal, twin_topic, strlen(twin_topic), " ", 1) != 0) {
IOTC_LOG(F("ERROR: Couldn't send the TWIN update request message"));
}
iotc_do_work(internal);
return 0;
}

Просмотреть файл

@ -284,6 +284,14 @@ int iotc_connect(IOTContext ctx, const char* scope, const char* keyORcert,
internal->mqttClient->setDefaultMessageHandler(messageArrived);
connectionStatusCallback(IOTC_CONNECTION_OK, (IOTContextInternal*)ctx);
iotc_do_work(internal);
const char* twin_topic = "$iothub/twin/GET/?$rid=0";
internal->messageId++; // next rid=1
if (mqtt_publish(internal, twin_topic, strlen(twin_topic), " ", 1) != 0) {
IOTC_LOG(F("ERROR: Couldn't send the TWIN update request message"));
}
iotc_do_work(internal);
return 0;
}