From c831f0772ff6fbf8acacdaf7314b8e16a7ff8982 Mon Sep 17 00:00:00 2001
From: Ilya Averyanov <av@rubybox.dev>
Date: Fri, 21 Jun 2024 14:38:41 +0300
Subject: [PATCH] feat(queue): handle renew_lease_timeout

---
 .../src/emqx_ds_shared_sub_group_sm.erl                | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/apps/emqx_ds_shared_sub/src/emqx_ds_shared_sub_group_sm.erl b/apps/emqx_ds_shared_sub/src/emqx_ds_shared_sub_group_sm.erl
index c6bdf9d93..5ddff8518 100644
--- a/apps/emqx_ds_shared_sub/src/emqx_ds_shared_sub_group_sm.erl
+++ b/apps/emqx_ds_shared_sub/src/emqx_ds_shared_sub_group_sm.erl
@@ -186,8 +186,8 @@ handle_renew_lease_timeout(GSM) ->
 %%-----------------------------------------------------------------------
 %% Updating state
 
-% handle_updating(GSM) ->
-%     GSM.
+handle_updating(GSM) ->
+    GSM.
 
 %%-----------------------------------------------------------------------
 %% Internal API
@@ -277,6 +277,6 @@ cancel_timer(GSM, Name) ->
 run_enter_callback(#{state := ?connecting} = GSM) ->
     handle_connecting(GSM);
 run_enter_callback(#{state := ?replaying} = GSM) ->
-    handle_replaying(GSM).
-% run_enter_callback(#{state := ?updating} = GSM) ->
-%     handle_updating(GSM).
+    handle_replaying(GSM);
+run_enter_callback(#{state := ?updating} = GSM) ->
+    handle_updating(GSM).