Skip to content

Commit 37ff93a

Browse files
authored
[ISSUE #6331] Optimlize DefaultMQPushConsumerImpl#subscribe method (#6332)
1 parent 0732f12 commit 37ff93a

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1246,7 +1246,7 @@ public void subscribe(String topic, String subExpression) throws MQClientExcepti
12461246

12471247
public void subscribe(String topic, String fullClassName, String filterClassSource) throws MQClientException {
12481248
try {
1249-
SubscriptionData subscriptionData = FilterAPI.buildSubscriptionData(topic, "*");
1249+
SubscriptionData subscriptionData = FilterAPI.buildSubscriptionData(topic, SubscriptionData.SUB_ALL);
12501250
subscriptionData.setSubString(fullClassName);
12511251
subscriptionData.setClassFilterMode(true);
12521252
subscriptionData.setFilterClassSource(filterClassSource);

0 commit comments

Comments
 (0)