Fix[MQB]: revisiting reopening logic (#998)

Signed-off-by: dorjesinpo <[email protected]>

Author: dorjesinpo

src/groups/mqb/mqbblp/mqbblp_cluster.cpp

@@ -2640,7 +2640,7 @@ void Cluster::configureQueue(
                                                        callback);
 }
 
-void Cluster::configureQueue(
+void Cluster::closeQueue(
     mqbi::Queue*                                 queue,
     const bmqp_ctrlmsg::QueueHandleParameters&   handleParameters,
     unsigned int                                 upstreamSubQueueId,
@@ -2651,10 +2651,10 @@ void Cluster::configureQueue(
     // PRECONDITIONS
     BSLS_ASSERT_SAFE(dispatcher()->inDispatcherThread(queue));
 
-    d_clusterOrchestrator.queueHelper().configureQueue(queue,
-                                                       handleParameters,
-                                                       upstreamSubQueueId,
-                                                       callback);
+    d_clusterOrchestrator.queueHelper().closeQueue(queue,
+                                                   handleParameters,
+                                                   upstreamSubQueueId,
+                                                   callback);
 }
 
 void Cluster::onQueueHandleCreated(mqbi::Queue*     queue,

src/groups/mqb/mqbblp/mqbblp_cluster.h

@@ -554,10 +554,10 @@ class Cluster : public mqbi::Cluster,
     /// specified `queue` with the specified `handleParameters` and invoke
     /// the specified `callback` when finished.
     void
-    configureQueue(mqbi::Queue*                               queue,
-                   const bmqp_ctrlmsg::QueueHandleParameters& handleParameters,
-                   unsigned int upstreamSubQueueId,
-                   const mqbi::Cluster::HandleReleasedCallback& callback)
+    closeQueue(mqbi::Queue*                                 queue,
+               const bmqp_ctrlmsg::QueueHandleParameters&   handleParameters,
+               unsigned int                                 upstreamSubQueueId,
+               const mqbi::Cluster::HandleReleasedCallback& callback)
         BSLS_KEYWORD_OVERRIDE;
 
     /// Invoked whenever an attempt was made to create a queue handle for

src/groups/mqb/mqbblp/mqbblp_clusterproxy.cpp

@@ -1153,7 +1153,7 @@ void ClusterProxy::configureQueue(
                                  callback);
 }
 
-void ClusterProxy::configureQueue(
+void ClusterProxy::closeQueue(
     mqbi::Queue*                                 queue,
     const bmqp_ctrlmsg::QueueHandleParameters&   handleParameters,
     unsigned int                                 upstreamSubQueueId,
@@ -1164,10 +1164,10 @@ void ClusterProxy::configureQueue(
     // PRECONDITIONS
     BSLS_ASSERT_SAFE(dispatcher()->inDispatcherThread(queue));
 
-    d_queueHelper.configureQueue(queue,
-                                 handleParameters,
-                                 upstreamSubQueueId,
-                                 callback);
+    d_queueHelper.closeQueue(queue,
+                             handleParameters,
+                             upstreamSubQueueId,
+                             callback);
 }
 
 void ClusterProxy::onQueueHandleCreated(mqbi::Queue*     queue,

src/groups/mqb/mqbblp/mqbblp_clusterproxy.h

@@ -469,10 +469,10 @@ class ClusterProxy : public mqbc::ClusterStateObserver,
     /// specified `queue` with the specified `handleParameters` and invoke
     /// the specified `callback` when finished.
     void
-    configureQueue(mqbi::Queue*                               queue,
-                   const bmqp_ctrlmsg::QueueHandleParameters& handleParameters,
-                   unsigned int upstreamSubQueueId,
-                   const mqbi::Cluster::HandleReleasedCallback& callback)
+    closeQueue(mqbi::Queue*                                 queue,
+               const bmqp_ctrlmsg::QueueHandleParameters&   handleParameters,
+               unsigned int                                 upstreamSubQueueId,
+               const mqbi::Cluster::HandleReleasedCallback& callback)
         BSLS_KEYWORD_OVERRIDE;
 
     /// Invoked whenever an attempt was made to create a queue handle for