[issue apache#221] fix notify retry topic subscribe duplicated.

echooymxq · Jan 12, 2024 · b640acd · b640acd
1 parent 7b556f9
commit b640acd
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/notify/NotifyManager.java b/mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/notify/NotifyManager.java
@@ -125,7 +125,7 @@ private void refresh() throws MQClientException {
         Set<String> thisTopicList = new HashSet<>();
         for (String topic : tmp) {
             try {
-                if (topic.equals(serviceConf.getClientRetryTopic())) {
+                if (topic.equals(serviceConf.getEventNotifyRetryTopic())) {
                     // notify by RetryDriver self
                     continue;
                 }