From 6c897c26aedf2843b203181f66e2ec3c94195b01 Mon Sep 17 00:00:00 2001
From: ieQu1 <99872536+ieQu1@users.noreply.github.com>
Date: Sat, 13 Apr 2024 10:23:52 +0200
Subject: [PATCH] fix(sessds): Commit session on unsubscribe

---
 apps/emqx/src/emqx_persistent_session_ds.erl | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/apps/emqx/src/emqx_persistent_session_ds.erl b/apps/emqx/src/emqx_persistent_session_ds.erl
index 0829b3fd3..5cae8487d 100644
--- a/apps/emqx/src/emqx_persistent_session_ds.erl
+++ b/apps/emqx/src/emqx_persistent_session_ds.erl
@@ -394,7 +394,8 @@ unsubscribe(
         undefined ->
             {error, ?RC_NO_SUBSCRIPTION_EXISTED};
         Subscription = #{subopts := SubOpts} ->
-            S = do_unsubscribe(ID, TopicFilter, Subscription, S0),
+            S1 = do_unsubscribe(ID, TopicFilter, Subscription, S0),
+            S = emqx_persistent_session_ds_state:commit(S1),
             {ok, Session#{s => S}, SubOpts}
     end.