Add Default option to set Priority

Author: sujit-baniya

src/Console/ConsumeCommand.php

@@ -25,7 +25,7 @@ class ConsumeCommand extends WorkCommand
                             {--tries=1 : Number of times to attempt a job before logging it failed}
                             {--rest=0 : Number of seconds to rest between jobs}
 
-                            {--max-priority=4}
+                            {--max-priority}
                             {--consumer-tag}
                             {--prefetch-size=0}
                             {--prefetch-count=1000}

src/Console/QueueDeclareCommand.php

@@ -12,7 +12,7 @@ class QueueDeclareCommand extends Command
                            {name : The name of the queue to declare}
                            {connection=rabbitmq : The name of the queue connection to use}
                            {--durable=1}
-                           {--max-priority=4}
+                           {--max-priority}
                            {--auto-delete=0}';
 
     protected $description = 'Declare queue';
@@ -32,10 +32,13 @@ public function handle(RabbitMQConnector $connector): void
 
             return;
         }
+
+        $arguments = [];
         $maxPriority = (int) $this->option('max-priority');
-        $arguments = [
-            'x-max-priority' => $maxPriority,
-        ];
+        if ($maxPriority) {
+            $arguments['x-max-priority'] = $maxPriority;
+        }
+
         $queue->declareQueue(
             $this->argument('name'),
             (bool) $this->option('durable'),

src/Consumer.php

@@ -91,6 +91,10 @@ public function daemon($connectionName, $queue, WorkerOptions $options)
         );
 
         $jobClass = $connection->getJobClass();
+        $arguments = [];
+        if ($this->maxPriority) {
+           $arguments['priority'] = ['I', $this->maxPriority];
+        }
 
         $this->channel->basic_consume(
             $queue,
@@ -123,7 +127,7 @@ function (AMQPMessage $message) use ($connection, $options, $connectionName, $qu
                 }
             },
             null,
-            ['priority' => ['I', $this->maxPriority]]
+            $arguments
         );
 
         while ($this->channel->is_consuming()) {

src/Queue/RabbitMQQueue.php

@@ -530,7 +530,6 @@ protected function createMessage($payload, int $attempts = 0): array
         $properties = [
             'content_type' => 'application/json',
             'delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT,
-            'priority' => 1,
         ];
 
         $currentPayload = json_decode($payload, true, 512);