fix: check for ASSIGNED state when loadQueuesInfo (#546)

Signed-off-by: dorjesinpo <[email protected]>
bloomberg · Dec 13, 2024 · e4f6990 · e4f6990
1 parent 8625cab
commit e4f6990
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/groups/mqb/mqbc/mqbc_clusterutil.cpp b/src/groups/mqb/mqbc/mqbc_clusterutil.cpp
@@ -2193,6 +2193,10 @@ void ClusterUtil::loadQueuesInfo(bsl::vector<bmqp_ctrlmsg::QueueInfo>* out,
         for (UriToQueueInfoMapCIter qCit = queuesInfoPerDomain.cbegin();
              qCit != queuesInfoPerDomain.cend();
              ++qCit) {
+            if (qCit->second->state() != ClusterStateQueueInfo::k_ASSIGNED) {
+                continue;  // CONTINUE
+            }
+
             bmqp_ctrlmsg::QueueInfo queueInfo;
             queueInfo.uri()         = qCit->second->uri().asString();
             queueInfo.partitionId() = qCit->second->partitionId();