yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(sessds): Commit session on unsubscribe

This commit is contained in:
ieQu1 2024-04-13 10:23:52 +02:00
parent 6c83bbe10b
commit 6c897c26ae
No known key found for this signature in database
GPG Key ID: 488654DF3FED6FDE
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
apps/emqx/src/emqx_persistent_session_ds.erl
View File

@ -394,7 +394,8 @@ unsubscribe(
undefined -> undefined ->
{error, ?RC_NO_SUBSCRIPTION_EXISTED}; {error, ?RC_NO_SUBSCRIPTION_EXISTED};
Subscription = #{subopts := SubOpts} -> 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} {ok, Session#{s => S}, SubOpts}
end. end.