Merge c75ef50 into 3183122

apache · Jul 7, 2021 · 2aafd0b · 2aafd0b
2 parents 3183122 + c75ef50
commit 2aafd0b
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java b/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
@@ -863,7 +863,7 @@ public void shutdown() {
         }
     }
 
-    public boolean registerConsumer(final String group, final MQConsumerInner consumer) {
+    public synchronized boolean registerConsumer(final String group, final MQConsumerInner consumer) {
         if (null == group || null == consumer) {
             return false;
         }
@@ -877,9 +877,9 @@ public boolean registerConsumer(final String group, final MQConsumerInner consum
         return true;
     }
 
-    public void unregisterConsumer(final String group) {
+    public synchronized void unregisterConsumer(final String group) {
         this.consumerTable.remove(group);
-        this.unregisterClientWithLock(null, group);
+        this.unregisterClient(null, group);
     }
 
     private void unregisterClientWithLock(final String producerGroup, final String consumerGroup) {