From a6f8716fffd78f10f22b78ad4b7a826602439d3b Mon Sep 17 00:00:00 2001
From: Tuan <tuanpm@live.com>
Date: Tue, 2 Apr 2019 14:54:50 +0700
Subject: [PATCH] Add mqtt sub protocol for websocket

---
 mqtt_client.c | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/mqtt_client.c b/mqtt_client.c
index db86724..a28aca9 100644
--- a/mqtt_client.c
+++ b/mqtt_client.c
@@ -368,6 +368,7 @@ esp_mqtt_client_handle_t esp_mqtt_client_init(const esp_mqtt_client_config_t *co
     esp_transport_handle_t ws = esp_transport_ws_init(tcp);
     ESP_MEM_CHECK(TAG, ws, goto _mqtt_init_failed);
     esp_transport_set_default_port(ws, MQTT_WS_DEFAULT_PORT);
+    esp_transport_ws_set_subprotocol(ws, "mqtt");
     esp_transport_list_add(client->transport_list, ws, "ws");
     if (config->transport == MQTT_TRANSPORT_OVER_WS) {
         client->config->scheme = create_string("ws", 2);
@@ -398,6 +399,7 @@ esp_mqtt_client_handle_t esp_mqtt_client_init(const esp_mqtt_client_config_t *co
 #if MQTT_ENABLE_WSS
     esp_transport_handle_t wss = esp_transport_ws_init(ssl);
     ESP_MEM_CHECK(TAG, wss, goto _mqtt_init_failed);
+    esp_transport_ws_set_subprotocol(wss, "mqtt");
     esp_transport_set_default_port(wss, MQTT_WSS_DEFAULT_PORT);
     esp_transport_list_add(client->transport_list, wss, "wss");
     if (config->transport == MQTT_TRANSPORT_OVER_WSS) {