Check against the correct clean session var for abandoning old inflights

mochi-mqtt · Aug 17, 2022 · ecbd07f · ecbd07f
1 parent ad8bf2a
commit ecbd07f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/server.go b/server/server.go
@@ -368,7 +368,7 @@ func (s *Server) EstablishConnection(lid string, c net.Conn, ac auth.Controller)
 
 	err = cl.StopCause() // Determine true cause of stop.
 
-	if !sessionPresent {
+	if cl.CleanSession {
 		s.clearAbandonedInflights(cl)
 	}