From 979fb58e50fcf7c29c35c29bdbd6294db40f0b47 Mon Sep 17 00:00:00 2001
From: Ilya Averyanov <av@rubybox.dev>
Date: Thu, 20 Jun 2024 21:12:15 +0300
Subject: [PATCH] feat(queue): use tp to trace new lease events

---
 .../emqx_persistent_session_ds_shared_subs.erl            | 8 +-------
 1 file changed, 1 insertion(+), 7 deletions(-)

diff --git a/apps/emqx/src/emqx_persistent_session_ds/emqx_persistent_session_ds_shared_subs.erl b/apps/emqx/src/emqx_persistent_session_ds/emqx_persistent_session_ds_shared_subs.erl
index 31be7cc0b..c4e929640 100644
--- a/apps/emqx/src/emqx_persistent_session_ds/emqx_persistent_session_ds_shared_subs.erl
+++ b/apps/emqx/src/emqx_persistent_session_ds/emqx_persistent_session_ds_shared_subs.erl
@@ -101,13 +101,7 @@ renew_streams(S0, #{agent := Agent0} = SharedSubS0) ->
     {StreamLeaseEvents, Agent1} = emqx_persistent_session_ds_shared_subs_agent:renew_streams(
         Agent0
     ),
-    StreamLeaseEvents =/= [] andalso
-        ?SLOG(
-            info, #{
-                msg => shared_subs_new_stream_lease_events, stream_lease_events => StreamLeaseEvents
-            }
-        ),
-    % StreamLeaseEvents =/= [] andalso ct:print("StreamLeaseEvents: ~p~n", [StreamLeaseEvents]),
+    ?tp(info, shared_subs_new_stream_lease_events, #{stream_lease_events => StreamLeaseEvents}),
     S1 = lists:foldl(
         fun
             (#{type := lease} = Event, S) -> accept_stream(Event, S);