From ade33e2c61073fccded2acd27df8558a4b716eb3 Mon Sep 17 00:00:00 2001 From: Georgy Sychev Date: Mon, 23 May 2022 23:41:30 +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 121d777ca..a19e884ae 100644 --- 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()).