From ec27ad144c65559d14bc988fea9a1e83b258134b Mon Sep 17 00:00:00 2001
From: mxsm <ljbmxsm@gmail.com>
Date: Mon, 13 Mar 2023 22:42:58 +0800
Subject: [PATCH] [ISSUE #6331]Optimlize DefaultMQPushConsumerImpl#subscribe
 method

---
 .../client/impl/consumer/DefaultMQPushConsumerImpl.java         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
index b8ece2ca012..e57579321cb 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
@@ -1246,7 +1246,7 @@ public void subscribe(String topic, String subExpression) throws MQClientExcepti
 
     public void subscribe(String topic, String fullClassName, String filterClassSource) throws MQClientException {
         try {
-            SubscriptionData subscriptionData = FilterAPI.buildSubscriptionData(topic, "*");
+            SubscriptionData subscriptionData = FilterAPI.buildSubscriptionData(topic, SubscriptionData.SUB_ALL);
             subscriptionData.setSubString(fullClassName);
             subscriptionData.setClassFilterMode(true);
             subscriptionData.setFilterClassSource(filterClassSource);