Ensure connectionLost/retry etc is invoked after keepalive disconnect #1276

src/MQTTAsyncUtils.c

@@ -2688,7 +2688,7 @@ static int MQTTAsync_disconnect_internal(MQTTAsync handle, int timeout)
 
 void MQTTProtocol_closeSession(Clients* c, int sendwill)
 {
-	MQTTAsync_closeSession(c, MQTTREASONCODE_SUCCESS, NULL);
+	nextOrClose((MQTTAsync)c->context, MQTTASYNC_DISCONNECTED, "MQTTProtocol_closeSession");
 }
 
 

src/MQTTClient.c

@@ -1980,7 +1980,7 @@ static int MQTTClient_disconnect_internal(MQTTClient handle, int timeout)
  */
 void MQTTProtocol_closeSession(Clients* c, int sendwill)
 {
-	MQTTClient_closeSession(c, MQTTREASONCODE_SUCCESS, NULL);
+	MQTTClient_disconnect_internal((MQTTClient)c->context, 0);
 }