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

[ISSUE #3066]producing a ghost consumer

Browse Source
This commit is contained in:
sunhangda
2021-07-02 15:36:53 +08:00
parent 2b236c3cd8
commit 36422c52c9
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
+3 -3
View File
@@ -863,7 +863,7 @@ public class MQClientInstance {
}
}
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 class MQClientInstance {
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) {