Fixing thread-unsafe QueueMgr and SchemaLeaneruse

dorjesinpo · dorjesinpo · commit 2bda5bdaef8c · 2025-02-19T12:32:19.000-05:00
Signed-off-by: dorjesinpo &lt;129227380+dorjesinpo@users.noreply.github.com&gt;
diff --git a/src/groups/bmq/bmqimp/bmqimp_queuemanager.cpp b/src/groups/bmq/bmqimp/bmqimp_queuemanager.cpp
@@ -294,7 +294,7 @@ QueueManager::observePushEvent(bmqt::CorrelationId* correlationId,
                                const bmqp::EventUtilQueueInfo& info)
 {
     // Update stats
-    const QueueSp queue = lookupQueueBySubscriptionIdLocked(
+    const QueueSp queue = lookupQueueBySubscriptionId(
         correlationId,
         subscriptionHandleId,
         info.d_header.queueId(),

Original file line number	Diff line number	Diff line change
`@@ -294,7 +294,7 @@ QueueManager::observePushEvent(bmqt::CorrelationId* correlationId,`
`294`	`294`	`const bmqp::EventUtilQueueInfo& info)`
`295`	`295`	`{`
`296`	`296`	`// Update stats`
`297`		`- const QueueSp queue = lookupQueueBySubscriptionIdLocked(`
	`297`	`+ const QueueSp queue = lookupQueueBySubscriptionId(`
`298`	`298`	`correlationId,`
`299`	`299`	`subscriptionHandleId,`
`300`	`300`	`info.d_header.queueId(),`