From cc501ae5a4a325561c618bd984cc3096a952bf9d Mon Sep 17 00:00:00 2001 From: wuxb02 Date: Mon, 10 Oct 2022 11:29:23 +0800 Subject: [PATCH] [ISSUE apache#931] fix filter message --- consumer/consumer.go | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/consumer/consumer.go b/consumer/consumer.go index 48591682..d5d5ba41 100644 --- a/consumer/consumer.go +++ b/consumer/consumer.go @@ -20,7 +20,6 @@ package consumer import ( "context" "fmt" - "github.com/apache/rocketmq-client-go/v2/hooks" "sort" "strconv" "strings" @@ -28,11 +27,11 @@ import ( "sync/atomic" "time" - "github.com/apache/rocketmq-client-go/v2/errors" - jsoniter "github.com/json-iterator/go" "github.com/tidwall/gjson" + "github.com/apache/rocketmq-client-go/v2/errors" + "github.com/apache/rocketmq-client-go/v2/hooks" "github.com/apache/rocketmq-client-go/v2/internal" "github.com/apache/rocketmq-client-go/v2/internal/remote" "github.com/apache/rocketmq-client-go/v2/internal/utils" @@ -883,7 +882,7 @@ func (dc *defaultConsumer) processPullResult(mq *primitive.MessageQueue, result // filter message according to tags msgListFilterAgain := msgs - if data.Tags.Len() > 0 && data.ClassFilterMode { + if data.Tags.Len() > 0 && !data.ClassFilterMode { msgListFilterAgain = make([]*primitive.MessageExt, 0) for _, msg := range msgs { _, exist := data.Tags.Contains(msg.GetTags())