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);