Running php-cs-fixer

Running php-cs-fixer to fix CS drift
php-enqueue · Jan 17, 2025 · 0baf319 · 0baf319
1 parent 19c7177
commit 0baf319
Show file tree

Hide file tree

Showing 20 changed files with 14 additions and 92 deletions.
diff --git a/AmqpConnectionFactory.php b/AmqpConnectionFactory.php
@@ -26,7 +26,7 @@ class AmqpConnectionFactory implements InteropAmqpConnectionFactory, DelayStrate
     private $client;
 
     /**
-     * @see \Enqueue\AmqpTools\ConnectionConfig for possible config formats and values
+     * @see ConnectionConfig for possible config formats and values
      *
      * @param array|string|null $config
      */
@@ -89,10 +89,10 @@ private function establishConnection(): BunnyClient
             $bunnyConfig['timeout'] = $this->config->getConnectionTimeout();
 
             // @see https://github.com/php-enqueue/enqueue-dev/issues/229
-//            $bunnyConfig['persistent'] = $this->config->isPersisted();
-//            if ($this->config->isPersisted()) {
-//                $bunnyConfig['path'] = 'enqueue';//$this->config->getOption('path', $this->config->getOption('vhost'));
-//            }
+            //            $bunnyConfig['persistent'] = $this->config->isPersisted();
+            //            if ($this->config->isPersisted()) {
+            //                $bunnyConfig['path'] = 'enqueue';//$this->config->getOption('path', $this->config->getOption('vhost'));
+            //            }
 
             if ($this->config->getHeartbeat()) {
                 $bunnyConfig['heartbeat'] = $this->config->getHeartbeat();

diff --git a/AmqpConsumer.php b/AmqpConsumer.php
@@ -48,7 +48,7 @@ public function __construct(AmqpContext $context, InteropAmqpQueue $queue)
         $this->flags = self::FLAG_NOPARAM;
     }
 
-    public function setConsumerTag(string $consumerTag = null): void
+    public function setConsumerTag(?string $consumerTag = null): void
     {
         $this->consumerTag = $consumerTag;
     }
@@ -98,7 +98,7 @@ public function receive(int $timeout = 0): ?Message
                 return $message;
             }
 
-            usleep(100000); //100ms
+            usleep(100000); // 100ms
         }
 
         return null;

diff --git a/AmqpContext.php b/AmqpContext.php
@@ -51,7 +51,6 @@ class AmqpContext implements InteropAmqpContext, DelayStrategyAware
      * Callable must return instance of \Bunny\Channel once called.
      *
      * @param Channel|callable $bunnyChannel
-     * @param array            $config
      */
     public function __construct($bunnyChannel, array $config)
     {
@@ -294,10 +293,7 @@ public function getBunnyChannel(): Channel
         if (false == $this->bunnyChannel) {
             $bunnyChannel = call_user_func($this->bunnyChannelFactory);
             if (false == $bunnyChannel instanceof Channel) {
-                throw new \LogicException(sprintf(
-                    'The factory must return instance of \Bunny\Channel. It returned %s',
-                    is_object($bunnyChannel) ? get_class($bunnyChannel) : gettype($bunnyChannel)
-                ));
+                throw new \LogicException(sprintf('The factory must return instance of \Bunny\Channel. It returned %s', is_object($bunnyChannel) ? $bunnyChannel::class : gettype($bunnyChannel)));
             }
 
             $this->bunnyChannel = $bunnyChannel;

diff --git a/AmqpProducer.php b/AmqpProducer.php
@@ -79,7 +79,7 @@ public function send(Destination $destination, Message $message): void
     /**
      * @return self
      */
-    public function setDeliveryDelay(int $deliveryDelay = null): Producer
+    public function setDeliveryDelay(?int $deliveryDelay = null): Producer
     {
         if (null === $this->delayStrategy) {
             throw DeliveryDelayNotSupportedException::providerDoestNotSupportIt();
@@ -98,7 +98,7 @@ public function getDeliveryDelay(): ?int
     /**
      * @return self
      */
-    public function setPriority(int $priority = null): Producer
+    public function setPriority(?int $priority = null): Producer
     {
         $this->priority = $priority;
 
@@ -113,7 +113,7 @@ public function getPriority(): ?int
     /**
      * @return self
      */
-    public function setTimeToLive(int $timeToLive = null): Producer
+    public function setTimeToLive(?int $timeToLive = null): Producer
     {
         $this->timeToLive = $timeToLive;
 

diff --git a/AmqpSubscriptionConsumer.php b/AmqpSubscriptionConsumer.php
@@ -47,7 +47,7 @@ public function consume(int $timeout = 0): void
         try {
             $this->context->getBunnyChannel()->getClient()->run(0 !== $timeout ? $timeout / 1000 : null);
         } catch (ClientException $e) {
-            if (0 === strpos($e->getMessage(), 'stream_select() failed') && $signalHandler->wasThereSignal()) {
+            if (str_starts_with($e->getMessage(), 'stream_select() failed') && $signalHandler->wasThereSignal()) {
                 return;
             }
 
@@ -63,7 +63,7 @@ public function consume(int $timeout = 0): void
     public function subscribe(Consumer $consumer, callable $callback): void
     {
         if (false == $consumer instanceof AmqpConsumer) {
-            throw new \InvalidArgumentException(sprintf('The consumer must be instance of "%s" got "%s"', AmqpConsumer::class, get_class($consumer)));
+            throw new \InvalidArgumentException(sprintf('The consumer must be instance of "%s" got "%s"', AmqpConsumer::class, $consumer::class));
         }
 
         if ($consumer->getConsumerTag() && array_key_exists($consumer->getConsumerTag(), $this->subscribers)) {
@@ -110,7 +110,7 @@ public function subscribe(Consumer $consumer, callable $callback): void
     public function unsubscribe(Consumer $consumer): void
     {
         if (false == $consumer instanceof AmqpConsumer) {
-            throw new \InvalidArgumentException(sprintf('The consumer must be instance of "%s" got "%s"', AmqpConsumer::class, get_class($consumer)));
+            throw new \InvalidArgumentException(sprintf('The consumer must be instance of "%s" got "%s"', AmqpConsumer::class, $consumer::class));
         }
 
         if (false == $consumer->getConsumerTag()) {

diff --git a/Tests/Spec/AmqpSendAndReceiveDelayedMessageWithDelayPluginStrategyTest.php b/Tests/Spec/AmqpSendAndReceiveDelayedMessageWithDelayPluginStrategyTest.php
@@ -18,9 +18,6 @@ public function test()
         $this->markTestIncomplete();
     }
 
-    /**
-     * {@inheritdoc}
-     */
     protected function createContext()
     {
         $factory = new AmqpConnectionFactory(getenv('AMQP_DSN'));
@@ -31,8 +28,6 @@ protected function createContext()
 
     /**
      * @param AmqpContext $context
-     *
-     * {@inheritdoc}
      */
     protected function createQueue(Context $context, $queueName)
     {

diff --git a/Tests/Spec/AmqpSendAndReceiveDelayedMessageWithDlxStrategyTest.php b/Tests/Spec/AmqpSendAndReceiveDelayedMessageWithDlxStrategyTest.php
@@ -13,9 +13,6 @@
  */
 class AmqpSendAndReceiveDelayedMessageWithDlxStrategyTest extends SendAndReceiveDelayedMessageFromQueueSpec
 {
-    /**
-     * {@inheritdoc}
-     */
     protected function createContext()
     {
         $factory = new AmqpConnectionFactory(getenv('AMQP_DSN'));
@@ -26,8 +23,6 @@ protected function createContext()
 
     /**
      * @param AmqpContext $context
-     *
-     * {@inheritdoc}
      */
     protected function createQueue(Context $context, $queueName)
     {

diff --git a/Tests/Spec/AmqpSendAndReceivePriorityMessagesFromQueueTest.php b/Tests/Spec/AmqpSendAndReceivePriorityMessagesFromQueueTest.php
@@ -12,9 +12,6 @@
  */
 class AmqpSendAndReceivePriorityMessagesFromQueueTest extends SendAndReceivePriorityMessagesFromQueueSpec
 {
-    /**
-     * {@inheritdoc}
-     */
     protected function createContext()
     {
         $factory = new AmqpConnectionFactory(getenv('AMQP_DSN'));
@@ -23,8 +20,6 @@ protected function createContext()
     }
 
     /**
-     * {@inheritdoc}
-     *
      * @param AmqpContext $context
      */
     protected function createQueue(Context $context, $queueName)

diff --git a/Tests/Spec/AmqpSendAndReceiveTimeToLiveMessagesFromQueueTest.php b/Tests/Spec/AmqpSendAndReceiveTimeToLiveMessagesFromQueueTest.php
@@ -12,9 +12,6 @@
  */
 class AmqpSendAndReceiveTimeToLiveMessagesFromQueueTest extends SendAndReceiveTimeToLiveMessagesFromQueueSpec
 {
-    /**
-     * {@inheritdoc}
-     */
     protected function createContext()
     {
         $factory = new AmqpConnectionFactory(getenv('AMQP_DSN'));
@@ -23,8 +20,6 @@ protected function createContext()
     }
 
     /**
-     * {@inheritdoc}
-     *
      * @param AmqpContext $context
      */
     protected function createQueue(Context $context, $queueName)

diff --git a/Tests/Spec/AmqpSendAndReceiveTimestampAsIntegerTest.php b/Tests/Spec/AmqpSendAndReceiveTimestampAsIntegerTest.php
@@ -10,9 +10,6 @@
  */
 class AmqpSendAndReceiveTimestampAsIntegerTest extends SendAndReceiveTimestampAsIntegerSpec
 {
-    /**
-     * {@inheritdoc}
-     */
     protected function createContext()
     {
         $factory = new AmqpConnectionFactory(getenv('AMQP_DSN'));

diff --git a/Tests/Spec/AmqpSendToAndReceiveFromQueueTest.php b/Tests/Spec/AmqpSendToAndReceiveFromQueueTest.php
@@ -12,9 +12,6 @@
  */
 class AmqpSendToAndReceiveFromQueueTest extends SendToAndReceiveFromQueueSpec
 {
-    /**
-     * {@inheritdoc}
-     */
     protected function createContext()
     {
         $factory = new AmqpConnectionFactory(getenv('AMQP_DSN'));
@@ -23,8 +20,6 @@ protected function createContext()
     }
 
     /**
-     * {@inheritdoc}
-     *
      * @param AmqpContext $context
      */
     protected function createQueue(Context $context, $queueName)

diff --git a/Tests/Spec/AmqpSendToAndReceiveFromTopicTest.php b/Tests/Spec/AmqpSendToAndReceiveFromTopicTest.php
@@ -13,9 +13,6 @@
  */
 class AmqpSendToAndReceiveFromTopicTest extends SendToAndReceiveFromTopicSpec
 {
-    /**
-     * {@inheritdoc}
-     */
     protected function createContext()
     {
         $factory = new AmqpConnectionFactory(getenv('AMQP_DSN'));
@@ -24,8 +21,6 @@ protected function createContext()
     }
 
     /**
-     * {@inheritdoc}
-     *
      * @param AmqpContext $context
      */
     protected function createTopic(Context $context, $topicName)

diff --git a/Tests/Spec/AmqpSendToAndReceiveNoWaitFromQueueTest.php b/Tests/Spec/AmqpSendToAndReceiveNoWaitFromQueueTest.php
@@ -12,9 +12,6 @@
  */
 class AmqpSendToAndReceiveNoWaitFromQueueTest extends SendToAndReceiveNoWaitFromQueueSpec
 {
-    /**
-     * {@inheritdoc}
-     */
     protected function createContext()
     {
         $factory = new AmqpConnectionFactory(getenv('AMQP_DSN'));
@@ -23,8 +20,6 @@ protected function createContext()
     }
 
     /**
-     * {@inheritdoc}
-     *
      * @param AmqpContext $context
      */
     protected function createQueue(Context $context, $queueName)

diff --git a/Tests/Spec/AmqpSendToAndReceiveNoWaitFromTopicTest.php b/Tests/Spec/AmqpSendToAndReceiveNoWaitFromTopicTest.php
@@ -13,9 +13,6 @@
  */
 class AmqpSendToAndReceiveNoWaitFromTopicTest extends SendToAndReceiveNoWaitFromTopicSpec
 {
-    /**
-     * {@inheritdoc}
-     */
     protected function createContext()
     {
         $factory = new AmqpConnectionFactory(getenv('AMQP_DSN'));
@@ -24,8 +21,6 @@ protected function createContext()
     }
 
     /**
-     * {@inheritdoc}
-     *
      * @param AmqpContext $context
      */
     protected function createTopic(Context $context, $topicName)

diff --git a/Tests/Spec/AmqpSendToTopicAndReceiveFromQueueTest.php b/Tests/Spec/AmqpSendToTopicAndReceiveFromQueueTest.php
@@ -14,9 +14,6 @@
  */
 class AmqpSendToTopicAndReceiveFromQueueTest extends SendToTopicAndReceiveFromQueueSpec
 {
-    /**
-     * {@inheritdoc}
-     */
     protected function createContext()
     {
         $factory = new AmqpConnectionFactory(getenv('AMQP_DSN'));
@@ -25,8 +22,6 @@ protected function createContext()
     }
 
     /**
-     * {@inheritdoc}
-     *
      * @param AmqpContext $context
      */
     protected function createQueue(Context $context, $queueName)
@@ -41,8 +36,6 @@ protected function createQueue(Context $context, $queueName)
     }
 
     /**
-     * {@inheritdoc}
-     *
      * @param AmqpContext $context
      */
     protected function createTopic(Context $context, $topicName)

diff --git a/Tests/Spec/AmqpSendToTopicAndReceiveNoWaitFromQueueTest.php b/Tests/Spec/AmqpSendToTopicAndReceiveNoWaitFromQueueTest.php
@@ -14,9 +14,6 @@
  */
 class AmqpSendToTopicAndReceiveNoWaitFromQueueTest extends SendToTopicAndReceiveNoWaitFromQueueSpec
 {
-    /**
-     * {@inheritdoc}
-     */
     protected function createContext()
     {
         $factory = new AmqpConnectionFactory(getenv('AMQP_DSN'));
@@ -25,8 +22,6 @@ protected function createContext()
     }
 
     /**
-     * {@inheritdoc}
-     *
      * @param AmqpContext $context
      */
     protected function createQueue(Context $context, $queueName)
@@ -41,8 +36,6 @@ protected function createQueue(Context $context, $queueName)
     }
 
     /**
-     * {@inheritdoc}
-     *
      * @param AmqpContext $context
      */
     protected function createTopic(Context $context, $topicName)

diff --git a/Tests/Spec/AmqpSslSendToAndReceiveFromQueueTest.php b/Tests/Spec/AmqpSslSendToAndReceiveFromQueueTest.php
@@ -19,9 +19,6 @@ public function test()
         parent::test();
     }
 
-    /**
-     * {@inheritdoc}
-     */
     protected function createContext()
     {
         $baseDir = realpath(__DIR__.'/../../../../');
@@ -44,8 +41,6 @@ protected function createContext()
     }
 
     /**
-     * {@inheritdoc}
-     *
      * @param AmqpContext $context
      */
     protected function createQueue(Context $context, $queueName)

diff --git a/Tests/Spec/AmqpSubscriptionConsumerConsumeFromAllSubscribedQueuesTest.php b/Tests/Spec/AmqpSubscriptionConsumerConsumeFromAllSubscribedQueuesTest.php
@@ -15,8 +15,6 @@ class AmqpSubscriptionConsumerConsumeFromAllSubscribedQueuesTest extends Subscri
 {
     /**
      * @return AmqpContext
-     *
-     * {@inheritdoc}
      */
     protected function createContext()
     {
@@ -30,8 +28,6 @@ protected function createContext()
 
     /**
      * @param AmqpContext $context
-     *
-     * {@inheritdoc}
      */
     protected function createQueue(Context $context, $queueName)
     {

diff --git a/Tests/Spec/AmqpSubscriptionConsumerConsumeUntilUnsubscribedTest.php b/Tests/Spec/AmqpSubscriptionConsumerConsumeUntilUnsubscribedTest.php
@@ -24,8 +24,6 @@ protected function tearDown(): void
 
     /**
      * @return AmqpContext
-     *
-     * {@inheritdoc}
      */
     protected function createContext()
     {
@@ -39,8 +37,6 @@ protected function createContext()
 
     /**
      * @param AmqpContext $context
-     *
-     * {@inheritdoc}
      */
     protected function createQueue(Context $context, $queueName)
     {