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* 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();