queues: add missing constants

Author: hex7c0

src/Queue/Connectors/RabbitMQConnector.php

@@ -21,6 +21,9 @@
 
 class RabbitMQConnector implements ConnectorInterface
 {
+    private const WORKER_DEFAULT='default';
+    private const WORKER_HORIZON='horizon';
+
     /**
      * @var Dispatcher
      */
@@ -74,18 +77,18 @@ public function connect(array $config): Queue
             $context->close();
         });
 
-        $worker = Arr::get($config, 'worker', 'default');
+        $worker = Arr::get($config, 'worker', self::WORKER_DEFAULT);
 
-        if ($worker === 'default') {
+        if ($worker === self::WORKER_DEFAULT) {
             return new RabbitMQQueue($context, $config);
         }
 
-        if ($worker === 'horizon') {
+        if ($worker === self::WORKER_HORIZON) {
             $this->dispatcher->listen(JobFailed::class, RabbitMQFailedEvent::class);
 
             return new HorizonRabbitMQQueue($context, $config);
         }
-        
+
         if (class_exists($worker)) {
             return new $worker($context, $config);
         }

src/Queue/RabbitMQQueue.php

@@ -1,7 +1,8 @@
-<?php
+<?php declare(strict_types=1);
 
 namespace VladimirYuldashev\LaravelQueueRabbitMQ\Queue;
 
+use Exception;
 use Illuminate\Contracts\Queue\Queue as QueueContract;
 use Illuminate\Queue\Queue;
 use Illuminate\Support\Facades\Config as FacadeConfig;
@@ -16,17 +17,18 @@
 use Psr\Log\LoggerInterface;
 use RuntimeException;
 use Throwable;
-use Exception;
 use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Jobs\RabbitMQJob;
 
 class RabbitMQQueue extends Queue implements QueueContract
 {
+    private const SLEEP_ON_ERROR=5;
     protected $sleepOnError;
 
     protected $queueName;
     protected $queueOptions;
     protected $exchangeOptions;
 
+
     /**
      * Alternative exchange options to use by producer.
      *
@@ -58,7 +60,7 @@ public function __construct(AmqpContext $context, array $config)
         $this->exchangeOptions['arguments'] = isset($this->exchangeOptions['arguments']) ?
             json_decode($this->exchangeOptions['arguments'], true) : [];
 
-        $this->sleepOnError = $config['sleep_on_error'] ?? 5;
+        $this->sleepOnError = $config['sleep_on_error'] ?? self::SLEEP_ON_ERROR;
     }
 
     /** {@inheritdoc} */