opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-21 05:44:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

replace hashset addAll method to constructure (#3879)

Browse Source 
Co-authored-by: 席朝东 <xichaodong@xichaodongdeMacBook-Pro.local>
This commit is contained in:
Tristeza
2022-05-08 14:41:33 +08:00
committed by GitHub
co-authored by 席朝东
parent c046404eed
commit d7e940a29a
2 changed files with 2 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
+1 -5
View File
@@ -999,11 +999,7 @@ public class DefaultMQPushConsumerImpl implements MQConsumerInner {
@Override
public Set<SubscriptionData> subscriptions() {
Set<SubscriptionData> subSet = new HashSet<SubscriptionData>();
subSet.addAll(this.rebalanceImpl.getSubscriptionInner().values());
return subSet;
return new HashSet<SubscriptionData>(this.rebalanceImpl.getSubscriptionInner().values());
}
@Override
client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
+1 -6
View File
@@ -273,12 +273,7 @@ public class DefaultMQProducerImpl implements MQProducerInner {
@Override
public Set<String> getPublishTopicList() {
Set<String> topicList = new HashSet<String>();
for (String key : this.topicPublishInfoTable.keySet()) {
topicList.add(key);
}
return topicList;
return new HashSet<String>(this.topicPublishInfoTable.keySet());
}
@Override