Running php-cs-fixer

Running php-cs-fixer to fix CS drift

Author: JimTools

Client/ChainExtension.php

@@ -67,7 +67,7 @@ public function __construct(array $extensions)
             }
 
             if (false == $extensionValid) {
-                throw new \LogicException(sprintf('Invalid extension given %s', get_class($extension)));
+                throw new \LogicException(sprintf('Invalid extension given %s', $extension::class));
             }
         });
     }

Client/Config.php

@@ -4,13 +4,13 @@
 
 class Config
 {
-    const TOPIC = 'enqueue.topic';
-    const COMMAND = 'enqueue.command';
-    const PROCESSOR = 'enqueue.processor';
-    const EXPIRE = 'enqueue.expire';
-    const PRIORITY = 'enqueue.priority';
-    const DELAY = 'enqueue.delay';
-    const CONTENT_TYPE = 'enqueue.content_type';
+    public const TOPIC = 'enqueue.topic';
+    public const COMMAND = 'enqueue.command';
+    public const PROCESSOR = 'enqueue.processor';
+    public const EXPIRE = 'enqueue.expire';
+    public const PRIORITY = 'enqueue.priority';
+    public const DELAY = 'enqueue.delay';
+    public const CONTENT_TYPE = 'enqueue.content_type';
 
     /**
      * @var string
@@ -66,7 +66,7 @@ public function __construct(
         string $defaultQueue,
         string $routerProcessor,
         array $transportConfig,
-        array $driverConfig
+        array $driverConfig,
     ) {
         $this->prefix = trim($prefix);
         $this->app = trim($app);
@@ -153,15 +153,15 @@ public function getDriverOptions(): array
     }
 
     public static function create(
-        string $prefix = null,
-        string $separator = null,
-        string $app = null,
-        string $routerTopic = null,
-        string $routerQueue = null,
-        string $defaultQueue = null,
-        string $routerProcessor = null,
+        ?string $prefix = null,
+        ?string $separator = null,
+        ?string $app = null,
+        ?string $routerTopic = null,
+        ?string $routerQueue = null,
+        ?string $defaultQueue = null,
+        ?string $routerProcessor = null,
         array $transportConfig = [],
-        array $driverConfig = []
+        array $driverConfig = [],
     ): self {
         return new static(
             $prefix ?: '',

Client/ConsumptionExtension/DelayRedeliveredMessageExtension.php

@@ -9,7 +9,7 @@
 
 class DelayRedeliveredMessageExtension implements MessageReceivedExtensionInterface
 {
-    const PROPERTY_REDELIVER_COUNT = 'enqueue.redelivery_count';
+    public const PROPERTY_REDELIVER_COUNT = 'enqueue.redelivery_count';
 
     /**
      * @var DriverInterface
@@ -24,8 +24,7 @@ class DelayRedeliveredMessageExtension implements MessageReceivedExtensionInterf
     private $delay;
 
     /**
-     * @param DriverInterface $driver
-     * @param int             $delay  The number of seconds the message should be delayed
+     * @param int $delay The number of seconds the message should be delayed
      */
     public function __construct(DriverInterface $driver, $delay)
     {

Client/ConsumptionExtension/SetRouterPropertiesExtension.php

@@ -14,9 +14,6 @@ class SetRouterPropertiesExtension implements MessageReceivedExtensionInterface
      */
     private $driver;
 
-    /**
-     * @param DriverInterface $driver
-     */
     public function __construct(DriverInterface $driver)
     {
         $this->driver = $driver;

Client/ConsumptionExtension/SetupBrokerExtension.php

@@ -18,9 +18,6 @@ class SetupBrokerExtension implements StartExtensionInterface
      */
     private $isDone;
 
-    /**
-     * @param DriverInterface $driver
-     */
     public function __construct(DriverInterface $driver)
     {
         $this->driver = $driver;

Client/DelegateProcessor.php

@@ -20,8 +20,6 @@ public function __construct(ProcessorRegistryInterface $registry)
     }
 
     /**
-     * {@inheritdoc}
-     *
      * @return string|object
      */
     public function process(InteropMessage $message, Context $context)

Client/Driver/AmqpDriver.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace  Enqueue\Client\Driver;
+namespace Enqueue\Client\Driver;
 
 use Enqueue\AmqpExt\AmqpProducer;
 use Enqueue\Client\Message;
@@ -45,11 +45,7 @@ public function createTransportMessage(Message $clientMessage): InteropMessage
         $priorityMap = $this->getPriorityMap();
         if ($priority = $clientMessage->getPriority()) {
             if (false == array_key_exists($priority, $priorityMap)) {
-                throw new \InvalidArgumentException(sprintf(
-                    'Cant convert client priority "%s" to transport one. Could be one of "%s"',
-                    $priority,
-                    implode('", "', array_keys($priorityMap))
-                ));
+                throw new \InvalidArgumentException(sprintf('Cant convert client priority "%s" to transport one. Could be one of "%s"', $priority, implode('", "', array_keys($priorityMap))));
             }
 
             $transportMessage->setPriority($priorityMap[$priority]);
@@ -58,7 +54,7 @@ public function createTransportMessage(Message $clientMessage): InteropMessage
         return $transportMessage;
     }
 
-    public function setupBroker(LoggerInterface $logger = null): void
+    public function setupBroker(?LoggerInterface $logger = null): void
     {
         $logger = $logger ?: new NullLogger();
         $log = function ($text, ...$args) use ($logger) {

Client/Driver/DbalDriver.php

@@ -16,7 +16,7 @@ public function __construct(DbalContext $context, ...$args)
         parent::__construct($context, ...$args);
     }
 
-    public function setupBroker(LoggerInterface $logger = null): void
+    public function setupBroker(?LoggerInterface $logger = null): void
     {
         $logger = $logger ?: new NullLogger();
         $log = function ($text, ...$args) use ($logger) {

Client/Driver/FsDriver.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace  Enqueue\Client\Driver;
+namespace Enqueue\Client\Driver;
 
 use Enqueue\Fs\FsContext;
 use Enqueue\Fs\FsDestination;
@@ -18,7 +18,7 @@ public function __construct(FsContext $context, ...$args)
         parent::__construct($context, ...$args);
     }
 
-    public function setupBroker(LoggerInterface $logger = null): void
+    public function setupBroker(?LoggerInterface $logger = null): void
     {
         $logger = $logger ?: new NullLogger();
         $log = function ($text, ...$args) use ($logger) {

Client/Driver/GenericDriver.php

@@ -39,7 +39,7 @@ class GenericDriver implements DriverInterface
     public function __construct(
         Context $context,
         Config $config,
-        RouteCollection $routeCollection
+        RouteCollection $routeCollection,
     ) {
         $this->context = $context;
         $this->config = $config;
@@ -120,7 +120,7 @@ public function sendToProcessor(Message $message): DriverSendResult
         return new DriverSendResult($queue, $transportMessage);
     }
 
-    public function setupBroker(LoggerInterface $logger = null): void
+    public function setupBroker(?LoggerInterface $logger = null): void
     {
     }