mqtt verbindet
This commit is contained in:
parent
8de0c068bb
commit
deb10fb82b
2 changed files with 5 additions and 2 deletions
|
@ -13,6 +13,7 @@
|
||||||
|
|
||||||
void user_init(void)
|
void user_init(void)
|
||||||
{
|
{
|
||||||
|
|
||||||
uart_set_baud(0, 115200);
|
uart_set_baud(0, 115200);
|
||||||
printf("SDK version: %s\n", sdk_system_get_sdk_version());
|
printf("SDK version: %s\n", sdk_system_get_sdk_version());
|
||||||
|
|
||||||
|
@ -22,6 +23,8 @@ void user_init(void)
|
||||||
|
|
||||||
wifi_available_semaphore = xSemaphoreCreateBinary();
|
wifi_available_semaphore = xSemaphoreCreateBinary();
|
||||||
|
|
||||||
|
xTaskCreate(mqtt_task, "mqtt_task", 1024, NULL, 1, NULL);
|
||||||
|
|
||||||
xTaskCreate(wifi_task, "wifi_task", 1024, NULL, 1, NULL);
|
xTaskCreate(wifi_task, "wifi_task", 1024, NULL, 1, NULL);
|
||||||
|
|
||||||
xTaskCreate(&httpd_task, "httpd_task", 1024, NULL, 2, NULL);
|
xTaskCreate(&httpd_task, "httpd_task", 1024, NULL, 2, NULL);
|
||||||
|
|
|
@ -22,7 +22,7 @@ extern "C" {
|
||||||
|
|
||||||
/* You can use http://test.mosquitto.org/ to test mqtt_client instead
|
/* You can use http://test.mosquitto.org/ to test mqtt_client instead
|
||||||
* of setting up your own MQTT server */
|
* of setting up your own MQTT server */
|
||||||
#define MQTT_HOST ("172.16.1.53")
|
#define MQTT_HOST ("172.16.0.42")
|
||||||
#define MQTT_PORT 1883
|
#define MQTT_PORT 1883
|
||||||
|
|
||||||
#define MQTT_USER NULL
|
#define MQTT_USER NULL
|
||||||
|
@ -157,4 +157,4 @@ extern "C" void mqtt_task(void *pvParameters) {
|
||||||
mqtt_network_disconnect(&network);
|
mqtt_network_disconnect(&network);
|
||||||
taskYIELD();
|
taskYIELD();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue