From e4f6990dc168ee8740b8ee7230ce35516c39981d Mon Sep 17 00:00:00 2001
From: dorjesinpo <129227380+dorjesinpo@users.noreply.github.com>
Date: Fri, 13 Dec 2024 04:34:46 -0500
Subject: [PATCH] fix: check for ASSIGNED state when loadQueuesInfo (#546)

Signed-off-by: dorjesinpo <129227380+dorjesinpo@users.noreply.github.com>
---
 src/groups/mqb/mqbc/mqbc_clusterutil.cpp | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/src/groups/mqb/mqbc/mqbc_clusterutil.cpp b/src/groups/mqb/mqbc/mqbc_clusterutil.cpp
index 61ad786e1b..95f0c64087 100644
--- 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();