SWR-19884 #comment Change RabbitMQ Queues Policies

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               | 27              | September 16th, 2025 | [Documentation](https://github.com/vyuldashev/laravel-queue-rabbitmq/blob/master/README.md) |
+| 1               | 28              | September 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.27 --ignore-platform-reqs
+composer require salesmessage/php-lib-rabbitmq:^1.28 --ignore-platform-reqs
 ```
 
 The package will automatically register itself.

composer.json

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

src/VhostsConsumers/AbstractVhostsConsumer.php

@@ -8,6 +8,7 @@
 use Illuminate\Queue\QueueManager;
 use Illuminate\Queue\WorkerOptions;
 use Illuminate\Support\Str;
+use PhpAmqpLib\Channel\AMQPChannel;
 use PhpAmqpLib\Connection\AMQPStreamConnection;
 use PhpAmqpLib\Exception\AMQPChannelClosedException;
 use PhpAmqpLib\Exception\AMQPConnectionClosedException;
@@ -651,6 +652,7 @@ protected function initConnection(): RabbitMQQueue
         );
 
         try {
+            /** @var AMQPChannel $channel */
             $channel = $connection->getChannel(true);
 
             $this->currentConnectionName = $connection->getConnectionName();

src/VhostsConsumers/DirectConsumer.php

@@ -41,6 +41,9 @@ protected function vhostDaemon($connectionName, WorkerOptions $options)
             try {
                 $this->connectionMutex->lock(self::MAIN_HANDLER_LOCK);
                 $amqpMessage = $this->channel->basic_get($this->currentQueueName);
+                if (null !== $amqpMessage) {
+                    $this->channel->basic_reject($amqpMessage->getDeliveryTag(), false);
+                }
                 $this->connectionMutex->unlock(self::MAIN_HANDLER_LOCK);
             } catch (AMQPProtocolChannelException|AMQPChannelClosedException $exception) {
                 $amqpMessage = null;
@@ -112,11 +115,6 @@ protected function startConsuming(): RabbitMQQueue
 
         $this->logInfo('startConsuming.init');
 
-        $arguments = [];
-        if ($this->maxPriority) {
-            $arguments['priority'] = ['I', $this->maxPriority];
-        }
-
         $this->jobsProcessed = 0;
 
         $connection = $this->initConnection();