[ISSUE #931] fix filter message (#932)

Co-authored-by: wuxb02 <[email protected]>
apache · Oct 31, 2022 · c197b50 · c197b50
1 parent 5779439
commit c197b50
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/consumer/consumer.go b/consumer/consumer.go
@@ -20,19 +20,18 @@ package consumer
 import (
 	"context"
 	"fmt"
-	"github.com/apache/rocketmq-client-go/v2/hooks"
 	"sort"
 	"strconv"
 	"strings"
 	"sync"
 	"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"
@@ -881,7 +880,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())