diff --git a/lib/roles/mqtt/mqtt.c b/lib/roles/mqtt/mqtt.c
index 4ba49c74f..08cff4427 100644
--- a/lib/roles/mqtt/mqtt.c
+++ b/lib/roles/mqtt/mqtt.c
@@ -2215,6 +2215,8 @@ lws_mqtt_client_send_subcribe(struct lws *wsi, lws_mqtt_subscribe_param_t *sub)
 			   (int)sub->packet_id);
 		lws_ser_wu16be(p, wsi->mqtt->ack_pkt_id);
 
+		nwsi->mqtt->client.aws_iot = wsi->mqtt->client.aws_iot;
+
 		if (lws_mqtt_str_advance(&mqtt_vh_payload, 2))
 			return 1;
 
@@ -2383,6 +2385,8 @@ lws_mqtt_client_send_unsubcribe(struct lws *wsi,
 			   (int)wsi->mqtt->ack_pkt_id);
 		lws_ser_wu16be(p, wsi->mqtt->ack_pkt_id);
 
+		nwsi->mqtt->client.aws_iot = wsi->mqtt->client.aws_iot;
+
 		if (lws_mqtt_str_advance(&mqtt_vh_payload, 2))
 			return 1;