SWR-17938 #comment Vhost Not Created Automatically

Author: NekloShcherbyna

README.md

@@ -11,14 +11,14 @@ Only the latest version will get new features. Bug fixes will be provided using
 
 | Package Version | Laravel Version | Bug Fixes Until  |                                                                                             |
 |-----------------|-----------------|------------------|---------------------------------------------------------------------------------------------|
-| 1               | 19              | April 23th, 2025 | [Documentation](https://github.com/vyuldashev/laravel-queue-rabbitmq/blob/master/README.md) |
+| 1               | 20              | April 23th, 2025 | [Documentation](https://github.com/vyuldashev/laravel-queue-rabbitmq/blob/master/README.md) |
 
 ## Installation
 
 You can install this package via composer using this command:
 
 ```
-composer require salesmessage/php-lib-rabbitmq:^1.19 --ignore-platform-reqs
+composer require salesmessage/php-lib-rabbitmq:^1.20 --ignore-platform-reqs
 ```
 
 The package will automatically register itself.

composer.json

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

src/Queue/RabbitMQQueueBatchable.php

@@ -65,7 +65,11 @@ protected function createChannel(): AMQPChannel
     {
         try {
             return parent::createChannel();
-        } catch (AMQPConnectionClosedException) {
+        } catch (AMQPConnectionClosedException $exception) {
+            if ($this->isVhostFailedException($exception) && (false === $this->createNotExistsVhost())) {
+                throw $exception;
+            }
+
             $this->reconnect();
             return parent::createChannel();
         }
@@ -148,5 +152,27 @@ private function addQueueToIndex(string $queue): bool
 
         return $isQueueActivated && $isVhostActivated;
     }
+
+    /**
+     * @param AMQPConnectionClosedException $exception
+     * @return bool
+     */
+    private function isVhostFailedException(AMQPConnectionClosedException $exception): bool
+    {
+        $dto = new ConnectionNameDto($this->getConnectionName());
+        $vhostName = (string) $dto->getVhostName();
+
+        $notFoundErrorMessage = sprintf('NOT_ALLOWED - vhost %s not found', $vhostName);
+        if ((403 === $exception->getCode()) && str_contains($exception->getMessage(), $notFoundErrorMessage)) {
+            return true;
+        }
+
+        $deletedErrorMessage = sprintf('CONNECTION_FORCED - vhost \'%s\' is deleted', $vhostName);
+        if (str_contains($exception->getMessage(), $deletedErrorMessage)) {
+            return true;
+        }
+
+        return false;
+    }
 }