fix(shared): backward-compatability fix

2022-05-23 23:41:30 +04:00 · 2022-05-23 23:41:30 +04:00 · ade33e2c61
parent 41331c5c1a
commit ade33e2c61
1 changed files with 2 additions and 2 deletions
--- a/src/emqx_shared_sub.erl
+++ b/src/emqx_shared_sub.erl
@ -217,8 +217,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;
-        {Group, _Sender, _Ref} -> {ok, Group}
+        {Group, _Sender, _Ref} -> {ok, Group};
+        _ -> error
    end.

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