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

fix(shared): dialyzer

This commit is contained in:
Georgy Sychev 2022-05-24 11:17:34 +04:00
parent ea313df2cc
commit d0cf112e17
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqx/src/emqx_session.erl
View File

@ -818,7 +818,7 @@ redispatch_shared_messages(#session{inflight = Inflight}) ->
%% Only QoS1 messages get redispatched, because QoS2 messages
%% must be sent to the same client, once they're in flight
({_, #inflight_data{message = #message{qos = ?QOS_2} = Msg}}) ->
?SLOG(warning, "Not redispatching qos2 msg: ~s", [Msg]);
?SLOG(warning, "Not redispatching qos2 msg: ~p", [Msg]);
({_, #inflight_data{message = #message{topic = Topic, qos = ?QOS_1} = Msg}}) ->
case emqx_shared_sub:get_group(Msg) of
{ok, Group} ->

2
apps/emqx/src/emqx_shared_sub.erl
View File

@ -225,7 +225,7 @@ get_group(Msg) ->
end.
%% @doc Negative ack dropped message due to inflight window or message queue being full.
-spec maybe_nack_dropped(emqx_types:message()) -> ok.
-spec maybe_nack_dropped(emqx_types:message()) -> boolean().
maybe_nack_dropped(Msg) ->
case get_group_ack(Msg) of
?NO_ACK -> false;