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

fix(shared): send to sub anyway

This commit is contained in:
Georgy Sychev 2022-05-24 15:22:06 +04:00
parent 1a5293e4b4
commit e175b3a1d6
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/emqx_shared_sub.erl
View File

@ -286,15 +286,17 @@ do_pick(Strategy, ClientId, SourceTopic, Group, Topic, FailedSubs) ->
%% Genuinely no subscriber
false;
[] ->
%% All offline? pick one anyway
%% We redispatch only to subs who dropped the message because inflight was full.
%% We try redispatch to subs who dropped the message because inflight was full.
Found = maps_find_by(FailedSubs, fun({SubPid, FailReason}) ->
FailReason == dropped andalso is_alive_sub(SubPid)
end),
case Found of
error -> false;
{ok, Dropped} ->
{retry, pick_subscriber(Group, Topic, Strategy, ClientId, SourceTopic, [Dropped])}
%% Found dropped client
{retry, pick_subscriber(Group, Topic, Strategy, ClientId, SourceTopic, [Dropped])};
error ->
%% All offline? pick one anyway
{retry, pick_subscriber(Group, Topic, Strategy, ClientId, SourceTopic, All)}
end;
Subs ->
%% More than one available