|
@@ -105,14 +105,23 @@ void mqttTask(void *pvParameters) {
|
|
|
|
|
|
void mqtt_init(void)
|
|
void mqtt_init(void)
|
|
{
|
|
{
|
|
- xTaskCreate(mqttTask, "MQTT-Task", 1024*10, NULL, 2, NULL);
|
|
|
|
|
|
+ xTaskCreatePinnedToCore(mqttTask, "MQTT-Task", 1024*10, NULL, 2, NULL,0);
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
void sendMQTTMessage(const char * topic, const char * data) {
|
|
void sendMQTTMessage(const char * topic, const char * data) {
|
|
if( connected ) {
|
|
if( connected ) {
|
|
|
|
+
|
|
int msg_id;
|
|
int msg_id;
|
|
|
|
+
|
|
|
|
+#ifdef MQTT_DEBUG
|
|
|
|
+ char topic_debug_str[100];
|
|
|
|
+ sprintf(topic_debug_str,"debug_env/%s",topic);
|
|
|
|
+ msg_id = esp_mqtt_client_publish(client, topic_debug_str, data, 0, 1, 0);
|
|
|
|
+#else
|
|
msg_id = esp_mqtt_client_publish(client, topic, data, 0, 1, 0);
|
|
msg_id = esp_mqtt_client_publish(client, topic, data, 0, 1, 0);
|
|
|
|
+#endif
|
|
|
|
+
|
|
ESP_LOGI(TAG, "sent publish successful, msg_id=%d %s %s", msg_id, topic, data);
|
|
ESP_LOGI(TAG, "sent publish successful, msg_id=%d %s %s", msg_id, topic, data);
|
|
}
|
|
}
|
|
else {
|
|
else {
|