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

chore(session): fix bad indent

This commit is contained in:
JianBo He 2022-05-19 09:23:58 +08:00
parent b345002e84
commit 411ee84a35
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/emqx_session.erl
View File

@ -644,19 +644,16 @@ redispatch_shared_messages(#session{inflight = Inflight}) ->
%% must be sent to the same client, once they're in flight %% must be sent to the same client, once they're in flight
({_, {#message{qos = ?QOS_2} = Msg, _}}) -> ({_, {#message{qos = ?QOS_2} = Msg, _}}) ->
?LOG(warning, "Not redispatching qos2 msg: ~s", [emqx_message:format(Msg)]); ?LOG(warning, "Not redispatching qos2 msg: ~s", [emqx_message:format(Msg)]);
({_, {#message{topic = Topic, qos = ?QOS_1} = Msg, _}}) -> ({_, {#message{topic = Topic, qos = ?QOS_1} = Msg, _}}) ->
case emqx_shared_sub:get_group(Msg) of case emqx_shared_sub:get_group(Msg) of
{ok, Group} -> {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 %% This is done to avoid dispatching back to caller
Delivery = #delivery{sender = self(), message = Msg}, Delivery = #delivery{sender = self(), message = Msg},
emqx_shared_sub:dispatch(Group, Topic, Delivery, [self()]); emqx_shared_sub:dispatch(Group, Topic, Delivery, [self()]);
_ -> _ ->
false false
end; end;
(_) -> (_) ->
ok ok
end, InflightList). end, InflightList).