[rocketmq] branch develop updated: [ISSUE #6331] Optimlize DefaultMQPushConsumerImpl#subscribe method (#6332)

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 37ff93a27b [ISSUE #6331] Optimlize DefaultMQPushConsumerImpl#subscribe 
method (#6332)
37ff93a27b is described below

commit 37ff93a27b034b2184144798d6c9f5bd00d63215
Author: mxsm <ljbm...@gmail.com>
AuthorDate: Tue Mar 14 08:12:53 2023 +0800

    [ISSUE #6331] Optimlize DefaultMQPushConsumerImpl#subscribe method (#6332)
---
 .../apache/rocketmq/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 b8ece2ca01..e57579321c 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 class DefaultMQPushConsumerImpl implements 
MQConsumerInner {
 
     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);