From 1a5293e4b42937b57e2af33573feda2c36cca42b Mon Sep 17 00:00:00 2001 From: Georgy Sychev Date: Mon, 23 May 2022 23:49:58 +0400 Subject: [PATCH] fix(shared): backward-compatability fix --- src/emqx_shared_sub.erl | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/emqx_shared_sub.erl b/src/emqx_shared_sub.erl index d21f83534..f2feceaf0 100644 --- 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()).