From b640acd90c5b0458b720947f5328ab6bc1c9056b Mon Sep 17 00:00:00 2001
From: echooymxq <echooy.mxq@gmail.com>
Date: Fri, 12 Jan 2024 18:15:55 +0800
Subject: [PATCH] [issue #221] fix notify retry topic subscribe duplicated.

---
 .../java/org/apache/rocketmq/mqtt/ds/notify/NotifyManager.java  | 2 +-
 1 file changed, 1 insertion(+), 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
index e027fa563..780a8e213 100644
--- 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;
                 }