Jelajahi Sumber

Merge pull request #11978 from keynslug/fix/crash-session-terminate

fix(sharesub): anticipate messages w/o redispatch header
Andrew Mayorov 2 tahun lalu
induk
melakukan
c2ad6142e5
1 mengubah file dengan 3 tambahan dan 1 penghapusan
  1. 3 1
      apps/emqx/src/emqx_shared_sub.erl

+ 3 - 1
apps/emqx/src/emqx_shared_sub.erl

@@ -242,7 +242,9 @@ with_redispatch_to(Msg, Group, Topic) ->
 is_redispatch_needed(#message{qos = ?QOS_0}) ->
 is_redispatch_needed(#message{qos = ?QOS_0}) ->
     false;
     false;
 is_redispatch_needed(#message{headers = #{redispatch_to := ?REDISPATCH_TO(_, _)}}) ->
 is_redispatch_needed(#message{headers = #{redispatch_to := ?REDISPATCH_TO(_, _)}}) ->
-    true.
+    true;
+is_redispatch_needed(#message{}) ->
+    false.
 
 
 %% @doc Redispatch shared deliveries to other members in the group.
 %% @doc Redispatch shared deliveries to other members in the group.
 redispatch(Messages0) ->
 redispatch(Messages0) ->