fix(shared): backward-compatability fix

2022-05-23 23:49:58 +04:00 · 2022-05-23 23:49:58 +04:00 · 1a5293e4b4
parent fae054bf0e
commit 1a5293e4b4
1 changed files with 2 additions and 2 deletions
--- a/src/emqx_shared_sub.erl
+++ b/src/emqx_shared_sub.erl
@ -219,8 +219,8 @@ get_group_ack(Msg) ->
 -spec(get_group(emqx_types:message()) -> {ok, any()} | error).
 get_group(Msg) ->
    case get_group_ack(Msg) of
-        ?NO_ACK -> error;
-        {_Type, Group, _Sender, _Ref} -> {ok, Group}
+        {_Type, Group, _Sender, _Ref} -> {ok, Group};
+        _ -> error
    end.

 -spec(is_ack_required(emqx_types:message()) -> boolean()).