diff --git a/src/groups/mqb/mqbblp/mqbblp_rootqueueengine.cpp b/src/groups/mqb/mqbblp/mqbblp_rootqueueengine.cpp index 06114746dd..38e729a14b 100644 --- a/src/groups/mqb/mqbblp/mqbblp_rootqueueengine.cpp +++ b/src/groups/mqb/mqbblp/mqbblp_rootqueueengine.cpp @@ -2061,15 +2061,7 @@ RootQueueEngine::head(const AppStateSp app) const // (virtual mqbi::QueueEngine) unsigned int RootQueueEngine::messageReferenceCount() const { - unsigned refCount = d_isFanout ? d_queueState_p->domain() - ->config() - - .mode() - .fanout() - .appIDs() - .size() - : 1; - + unsigned int refCount = d_queueState_p->storage()->numVirtualStorages(); unsigned int numNegative = d_queueState_p->storage()->numAutoConfirms(); BSLS_ASSERT_SAFE(numNegative <= refCount);