From 411ee84a359b39cf0268f4f60932bb8d9d3a9b3f Mon Sep 17 00:00:00 2001 From: JianBo He Date: Thu, 19 May 2022 09:23:58 +0800 Subject: [PATCH] chore(session): fix bad indent --- src/emqx_session.erl | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/src/emqx_session.erl b/src/emqx_session.erl index ae4d035c3..d01f33e6a 100644 --- a/src/emqx_session.erl +++ b/src/emqx_session.erl @@ -644,19 +644,16 @@ redispatch_shared_messages(#session{inflight = Inflight}) -> %% must be sent to the same client, once they're in flight ({_, {#message{qos = ?QOS_2} = Msg, _}}) -> ?LOG(warning, "Not redispatching qos2 msg: ~s", [emqx_message:format(Msg)]); - ({_, {#message{topic = Topic, qos = ?QOS_1} = Msg, _}}) -> case emqx_shared_sub:get_group(Msg) of {ok, Group} -> - %% Note that dispatch is called with self() in failed subs + %% Note that dispatch is called with self() in failed subs %% This is done to avoid dispatching back to caller Delivery = #delivery{sender = self(), message = Msg}, emqx_shared_sub:dispatch(Group, Topic, Delivery, [self()]); - _ -> false end; - (_) -> ok end, InflightList).