SWR-15367 #comment Bandwidth Splitting

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               | 11              | December 26th, 2024 | [Documentation](https://github.com/vyuldashev/laravel-queue-rabbitmq/blob/master/README.md) |
+| 1               | 12              | December 26th, 2024 | [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.11 --ignore-platform-reqs
+composer require salesmessage/php-lib-rabbitmq:^1.12 --ignore-platform-reqs
 ```
 
 The package will automatically register itself.

composer.json

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

src/Console/ScanVhostsCommand.php

@@ -91,18 +91,20 @@ private function processVhost(array $vhostApiData): ?VhostApiDto
         $indexedSuccessfully = $this->internalStorageManager->indexVhost($vhostDto, $this->groups);
         if (!$indexedSuccessfully) {
             $this->warn(sprintf(
-                'Skip indexation vhost: "%s". Messages ready: %d.',
+                'Skip indexation vhost: "%s". Messages ready: %d. Messages unacknowledged: %d.',
                 $vhostDto->getName(),
-                $vhostDto->getMessagesReady()
+                $vhostDto->getMessagesReady(),
+                $vhostDto->getMessagesUnacknowledged()
             ));
 
             return null;
         }
 
         $this->info(sprintf(
-            'Successfully indexed vhost: "%s". Messages ready: %d.',
+            'Successfully indexed vhost: "%s". Messages ready: %d. Messages unacknowledged: %d.',
             $vhostDto->getName(),
-            $vhostDto->getMessagesReady()
+            $vhostDto->getMessagesReady(),
+            $vhostDto->getMessagesUnacknowledged()
         ));
 
         $vhostQueues = $this->queueService->getAllVhostQueues($vhostDto);
@@ -171,20 +173,22 @@ private function processVhostQueue(array $queueApiData): ?QueueApiDto
         $indexedSuccessfully = $this->internalStorageManager->indexQueue($queueApiDto, $this->groups);
         if (!$indexedSuccessfully) {
             $this->warn(sprintf(
-                'Skip indexation queue: "%s". Vhost: %s. Messages ready: %d.',
+                'Skip indexation queue: "%s". Vhost: %s. Messages ready: %d. Messages unacknowledged: %d.',
                 $queueApiDto->getName(),
                 $queueApiDto->getVhostName(),
-                $queueApiDto->getMessagesReady()
+                $queueApiDto->getMessagesReady(),
+                $queueApiDto->getMessagesUnacknowledged()
             ));
 
             return null;
         }
 
         $this->info(sprintf(
-            'Successfully indexed queue: "%s". Vhost: %s. Messages ready: %d.',
+            'Successfully indexed queue: "%s". Vhost: %s. Messages ready: %d. Messages unacknowledged: %d.',
             $queueApiDto->getName(),
             $queueApiDto->getVhostName(),
-            $queueApiDto->getMessagesReady()
+            $queueApiDto->getMessagesReady(),
+            $queueApiDto->getMessagesUnacknowledged()
         ));
 
         return $queueApiDto;

src/Services/InternalStorageManager.php

@@ -75,7 +75,7 @@ public function getVhostQueues(string $vhostName, string $by = 'name', bool $alp
      */
     public function indexVhost(VhostApiDto $vhostDto, array $groups = []): bool
     {
-        if ($vhostDto->getMessagesReady() > 0) {
+        if (($vhostDto->getMessagesReady() > 0) || ($vhostDto->getMessagesUnacknowledged() > 0)) {
             return $this->addVhost($vhostDto, $groups);
         }
 
@@ -185,7 +185,7 @@ private function getVhostStorageKeyPrefix(): string
      */
     public function indexQueue(QueueApiDto $queueDto, array $groups): bool
     {
-        if ($queueDto->getMessagesReady() > 0) {
+        if (($queueDto->getMessagesReady() > 0) || ($queueDto->getMessagesUnacknowledged() > 0)) {
             return $this->addQueue($queueDto, $groups);
         }