SWR-18338: RabbitMQ Switch Logic

Author: pupsick

composer.json

@@ -34,7 +34,7 @@
     },
     "extra": {
         "branch-alias": {
-            "dev-master": "1.23-dev"
+            "dev-master": "1.24-dev"
         },
         "laravel": {
             "providers": [

src/VhostsConsumers/AbstractVhostsConsumer.php

@@ -566,24 +566,21 @@ protected function updateLastProcessedAt()
      */
     protected function initConnection(): RabbitMQQueue
     {
-        if ($this->connection) {
+        if ($this->channel) {
             try {
-                $this->connection->close();
+                $this->channel->close();
             } catch (\Exception $e) {
+                // Ignore close errors
             }
-            $this->connection = null;
+            $this->channel = null;
         }
 
         $connection = $this->manager->connection(
             ConnectionNameDto::getVhostConnectionName($this->currentVhostName, $this->configConnectionName)
         );
 
         try {
-            if (!$connection->isConnected()) {
-                $connection->reconnect();
-            }
-
-            $channel = $connection->getChannel();
+            $channel = $connection->getChannel(true);
 
             $this->currentConnectionName = $connection->getConnectionName();