About AngeloMiele94

The 2 Tasks in the Project are: AppControllerFire_Env AppControllerFire_Mov   They sent to the broker 2 different messages with different topics. static void AppControllerFire_Env(void* pvParameters) { BCDS_UNUSED(pvParameters); Retcode_T retcode = RETCODE_OK; Sensor_Value_T sensorValue; char publishBuffer[APP_MQTT_DATA_BUFFER_SIZE]; /* const char *publishDataFormat = "Environmental Data -\n" "\r\tHumidity : %ld [%%] \n" "\r\tPressure : %ld [bar] \n" "\r\tTemperature : %f\xf8 [°C] \n" "\r\tAcceleration X : %ld [m/s^2] \n" "\r\tAcceleration Y : %ld [m/s^2] \n" "\r\tAcceleration Z : %ld [m/s^2] \n"; */ char *publishDataFormat = "{ " "\"Humidity\":%ld," "\"Pressure\":%ld," "\"Temperature\":%f," "}"; memset(&sensorValue, 0x00, sizeof(sensorValue)); #if APP_MQTT_SECURE_ENABLE uint64_t sntpTimeStampFromServer = 0UL; /* We Synchronize the node with the SNTP server for time-stamp. * Since there is no point in doing a HTTPS communication without a valid time */ do { retcode = SNTP_GetTimeFromServer(&sntpTimeStampFromServer, APP_RESPONSE_FROM_SNTP_SERVER_TIMEOUT); if ((RETCODE_OK != retcode) || (0UL == sntpTimeStampFromServer)) { printf("AppControllerFire : SNTP server time was not synchronized. Retrying...\r\n"); } } while (0UL == sntpTimeStampFromServer); BCDS_UNUSED(sntpTimeStampFromServer); /* Copy of sntpTimeStampFromServer will be used be HTTPS for TLS handshake */ #endif /* APP_MQTT_SECURE_ENABLE */ if (RETCODE_OK == retcode) { retcode = MQTT_ConnectToBroker(&MqttConnectInfo, MQTT_CONNECT_TIMEOUT_IN_MS); if (RETCODE_OK != retcode) { printf("AppControllerFire : MQTT connection to the broker failed \n\r"); } } if (RETCODE_OK == retcode) { // retcode = MQTT_SubsribeToTopic(&MqttSubscribeInfo_Env, MQTT_SUBSCRIBE_TIMEOUT_IN_MS); retcode = RETCODE_OK; if (RETCODE_OK != retcode) { printf("AppControllerFire : MQTT subscribe failed \n\r"); } } if (RETCODE_OK != retcode) { /* We raise error and still proceed to publish data periodically */ Retcode_RaiseError(retcode); vTaskSuspend(NULL); } /* A function that implements a task must not exit or attempt to return to its caller function as there is nothing to return to. */ while (1) { /* Resetting / clearing the necessary buffers / variables for re-use */ retcode = RETCODE_OK; /* Check whether the WLAN network connection is available */ retcode = AppControllerValidateWLANConnectivity(); if (RETCODE_OK == retcode) { retcode = Sensor_GetData(&sensorValue); } if (RETCODE_OK == retcode) { int32_t length = snprintf((char *) publishBuffer, APP_MQTT_DATA_BUFFER_SIZE, publishDataFormat, (long int) sensorValue.RH, (sensorValue.Pressure /= 1000), (sensorValue.Temp /= 1000)); MqttPublishInfo_Env.Payload = publishBuffer; MqttPublishInfo_Env.PayloadLength = length; retcode = MQTT_PublishToTopic(&MqttPublishInfo_Env, MQTT_PUBLISH_TIMEOUT_IN_MS); if (RETCODE_OK != retcode) { printf("AppControllerFire : MQTT publish failed \n\r"); } } if (RETCODE_OK != retcode) { Retcode_RaiseError(retcode); } vTaskDelay(APP_MQTT_DATA_PUBLISH_PERIODICITY_Env); } } static void AppControllerFire_Mov(void* pvParameters) { BCDS_UNUSED(pvParameters); Retcode_T retcode = RETCODE_OK; Sensor_Value_T sensorValue; char publishBuffer[APP_MQTT_DATA_BUFFER_SIZE]; /* const char *publishDataFormat = "Environmental Data -\n" "\r\tHumidity : %ld [%%] \n" "\r\tPressure : %ld [bar] \n" "\r\tTemperature : %f\xf8 [°C] \n" "\r\tAcceleration X : %ld [m/s^2] \n" "\r\tAcceleration Y : %ld [m/s^2] \n" "\r\tAcceleration Z : %ld [m/s^2] \n"; */ char *publishDataFormat = "{ " "\"AccelerationX\":%ld," "\"AccelerationY\":%ld," "\"AccelerationZ\":%ld" "}"; memset(&sensorValue, 0x00, sizeof(sensorValue)); #if APP_MQTT_SECURE_ENABLE uint64_t sntpTimeStampFromServer = 0UL; /* We Synchronize the node with the SNTP server for time-stamp. * Since there is no point in doing a HTTPS communication without a valid time */ do { retcode = SNTP_GetTimeFromServer(&sntpTimeStampFromServer, APP_RESPONSE_FROM_SNTP_SERVER_TIMEOUT); if ((RETCODE_OK != retcode) || (0UL == sntpTimeStampFromServer)) { printf("AppControllerFire : SNTP server time was not synchronized. Retrying...\r\n"); } } while (0UL == sntpTimeStampFromServer); BCDS_UNUSED(sntpTimeStampFromServer); /* Copy of sntpTimeStampFromServer will be used be HTTPS for TLS handshake */ #endif /* APP_MQTT_SECURE_ENABLE */ if (RETCODE_OK == retcode) { retcode = MQTT_ConnectToBroker(&MqttConnectInfo, MQTT_CONNECT_TIMEOUT_IN_MS); if (RETCODE_OK != retcode) { printf("AppControllerFire : MQTT connection to the broker failed \n\r"); } } if (RETCODE_OK == retcode) { // retcode = MQTT_SubsribeToTopic(&MqttSubscribeInfo_Mov, MQTT_SUBSCRIBE_TIMEOUT_IN_MS); retcode = RETCODE_OK; if (RETCODE_OK != retcode) { printf("AppControllerFire : MQTT subscribe failed \n\r"); } } if (RETCODE_OK != retcode) { /* We raise error and still proceed to publish data periodically */ Retcode_RaiseError(retcode); vTaskSuspend(NULL); } /* A function that implements a task must not exit or attempt to return to its caller function as there is nothing to return to. */ while (1) { /* Resetting / clearing the necessary buffers / variables for re-use */ retcode = RETCODE_OK; /* Check whether the WLAN network connection is available */ retcode = AppControllerValidateWLANConnectivity(); if (RETCODE_OK == retcode) { retcode = Sensor_GetData(&sensorValue); } if (RETCODE_OK == retcode) { int32_t length = snprintf((char *) publishBuffer, APP_MQTT_DATA_BUFFER_SIZE, publishDataFormat, sensorValue.Accel.X, sensorValue.Accel.Y, sensorValue.Accel.Z); MqttPublishInfo_Mov.Payload = publishBuffer; MqttPublishInfo_Mov.PayloadLength = length; retcode = MQTT_PublishToTopic(&MqttPublishInfo_Mov, MQTT_PUBLISH_TIMEOUT_IN_MS); if (RETCODE_OK != retcode) { printf("AppControllerFire : MQTT publish failed \n\r"); } } if (RETCODE_OK != retcode) { Retcode_RaiseError(retcode); } vTaskDelay(APP_MQTT_DATA_PUBLISH_PERIODICITY_Mov); } }     ... View more