Skip to content

Commit 5d169b5

Browse files
authored
Gracefully disconnect MQTT (#23)
* Gracefully disconnect MQTT * Add MG_F_SEND_AND_CLOSE flag to disconnect
1 parent 2b43e81 commit 5d169b5

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/mgos_mqtt_conn.c

+2-1
Original file line numberDiff line numberDiff line change
@@ -490,7 +490,8 @@ void mgos_mqtt_conn_disconnect(struct mgos_mqtt_conn *c) {
490490
if (c == NULL) return;
491491
c->reconnect_timeout_ms = -1; // Prevent reconnect.
492492
if (c->nc != NULL) {
493-
c->nc->flags |= MG_F_CLOSE_IMMEDIATELY;
493+
mg_mqtt_disconnect(c->nc);
494+
c->nc->flags |= MG_F_SEND_AND_CLOSE;
494495
}
495496
}
496497

0 commit comments

Comments
 (0)