fix: clean app subscriptions on reconfigure

Signed-off-by: dorjesinpo <[email protected]>
bloomberg · Oct 16, 2024 · 302149c · 302149c
1 parent 71b4dab
commit 302149c
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/src/groups/mqb/mqbblp/mqbblp_rootqueueengine.cpp b/src/groups/mqb/mqbblp/mqbblp_rootqueueengine.cpp
@@ -415,7 +415,13 @@ int RootQueueEngine::initializeAppId(const bsl::string& appId,
                                      bsl::ostream&      errorDescription,
                                      unsigned int       upstreamSubQueueId)
 {
-    if (d_apps.findByKey1(appId) != d_apps.end()) {
+    Apps::iterator iter = d_apps.findByKey1(appId);
+
+    if (iter != d_apps.end()) {
+
+        mqbconfm::Expression empty(d_allocator_p);
+        iter->value()->setSubscription(empty);
+
         // Don't reconfigure an AppId that is already registered.
         return 0;  // RETURN
     }
@@ -439,9 +445,7 @@ int RootQueueEngine::initializeAppId(const bsl::string& appId,
     }
     BSLS_ASSERT_SAFE(!appKey.isNull());
 
-    Apps::iterator iter = makeSubStream(appId,
-                                        AppKeyCount(appKey, 0),
-                                        upstreamSubQueueId);
+    iter = makeSubStream(appId, AppKeyCount(appKey, 0), upstreamSubQueueId);
 
     iter->value()->authorize(appKey, ordinal);