Format code by the latest cs-fixer. (#6617)

.php-cs-fixer.php

@@ -94,7 +94,9 @@ return (new PhpCsFixer\Config())
         'single_quote' => true,
         'standardize_not_equals' => true,
         'multiline_comment_opening_closing' => true,
-        'nullable_type_declaration_for_default_null_value' => true, // Since PHP 8.3, default null values can be declared as nullable.
+        // Since PHP 8.3, default null values can be declared as nullable.
+        'nullable_type_declaration_for_default_null_value' => true,
+        'single_line_empty_body' => false,
     ])
     ->setFinder(
         PhpCsFixer\Finder::create()

CHANGELOG-3.1.md

@@ -4,6 +4,10 @@
 
 - [#6613](https://github.com/hyperf/hyperf/pull/6613) Added event of release connection for `hyperf/pool`.
 
+## Optimized
+
+- [#6616](https://github.com/hyperf/hyperf/pull/6616) [#6617](https://github.com/hyperf/hyperf/pull/6617) Format code by the latest `cs-fixer`.
+
 # v3.1.14 - 2024-03-21
 
 ## Fixed

bootstrap.php

@@ -32,4 +32,4 @@ AstVisitorRegistry::insert(ProxyCallVisitor::class);
 // Register Property Handler.
 RegisterInjectPropertyHandler::register();
 
-(new RegisterPropertyHandlerListener())->process(new \stdClass());
+(new RegisterPropertyHandlerListener())->process(new stdClass());

composer.json

@@ -38,7 +38,7 @@
         "fakerphp/faker": "^1.23",
         "fig/http-message-util": "^1.1.2",
         "filp/whoops": "^2.7",
-        "friendsofphp/php-cs-fixer": "~3.16.0",
+        "friendsofphp/php-cs-fixer": "^3.52",
         "google/common-protos": "^3.2|^4.4",
         "google/protobuf": "^3.6.1",
         "grpc/grpc": "^1.15",

phpstan.neon.dist

@@ -16,7 +16,6 @@ parameters:
     - %currentWorkingDirectory%/src/*/class_map/*
     - %currentWorkingDirectory%/src/di/src/Resolver/FactoryResolver.php
     - %currentWorkingDirectory%/src/config-zookeeper/src/Client.php
-    - %currentWorkingDirectory%/src/contract/*
     - %currentWorkingDirectory%/src/database/*
     - %currentWorkingDirectory%/src/database-pgsql/*
     - %currentWorkingDirectory%/src/db/src/PgSQL/*
@@ -25,7 +24,6 @@ parameters:
     - %currentWorkingDirectory%/src/grpc/*
     - %currentWorkingDirectory%/src/grpc-server/*
     - %currentWorkingDirectory%/src/ide-helper/*
-    - %currentWorkingDirectory%/src/swagger/*
     - %currentWorkingDirectory%/src/validation/*
     - %currentWorkingDirectory%/src/view/src/Engine/*
     - %currentWorkingDirectory%/src/server/src/SwowServer.php

src/amqp/src/AMQPConnection.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp;
 
 use Hyperf\Amqp\Exception\LoopBrokenException;

src/amqp/src/Annotation/Consumer.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Annotation;
 
 use Attribute;

src/amqp/src/Annotation/Producer.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Annotation;
 
 use Attribute;

src/amqp/src/Builder.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp;
 
 use Hyperf\Amqp\Message\MessageInterface;

src/amqp/src/Builder/Builder.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Builder;
 
 use PhpAmqpLib\Wire\AMQPTable;

src/amqp/src/Builder/ExchangeBuilder.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Builder;
 
 use Hyperf\Amqp\Message\Type;
@@ -32,7 +33,7 @@ class ExchangeBuilder extends Builder
         return $this;
     }
 
-    public function getType(): Type|string
+    public function getType(): string|Type
     {
         return $this->type;
     }
@@ -42,7 +43,7 @@ class ExchangeBuilder extends Builder
         return $this->type instanceof Type ? $this->type->value : $this->type;
     }
 
-    public function setType(Type|string $type): static
+    public function setType(string|Type $type): static
     {
         $this->type = $type;
         return $this;

src/amqp/src/Builder/QueueBuilder.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Builder;
 
 use PhpAmqpLib\Wire\AMQPTable;

src/amqp/src/ConfigProvider.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp;
 
 use Hyperf\Amqp\Listener\BeforeMainServerStartListener;

src/amqp/src/ConnectionFactory.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp;
 
 use Hyperf\Amqp\Exception\NotSupportedException;

src/amqp/src/Constants.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp;
 
 class Constants

src/amqp/src/Consumer.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp;
 
 use Hyperf\Amqp\Event\AfterConsume;

src/amqp/src/ConsumerFactory.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp;
 
 use Hyperf\Contract\StdoutLoggerInterface;

src/amqp/src/ConsumerManager.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp;
 
 use Hyperf\Amqp\Annotation\Consumer as ConsumerAnnotation;

src/amqp/src/Event/AfterConsume.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Event;
 
 use Hyperf\Amqp\Message\ConsumerMessageInterface;

src/amqp/src/Event/BeforeConsume.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Event;
 
 use Hyperf\Amqp\Message\ConsumerMessageInterface;

src/amqp/src/Event/ConsumeEvent.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Event;
 
 use Hyperf\Amqp\Message\ConsumerMessageInterface;

src/amqp/src/Event/FailToConsume.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Event;
 
 use Hyperf\Amqp\Message\ConsumerMessageInterface;

src/amqp/src/Event/WaitTimeout.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Event;
 
 class WaitTimeout extends ConsumeEvent

src/amqp/src/Exception/LoopBrokenException.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Exception;
 
 use RuntimeException;

src/amqp/src/Exception/MaxConsumptionException.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Exception;
 
 use Exception;

src/amqp/src/Exception/MessageException.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Exception;
 
 use Exception;

src/amqp/src/Exception/NotSupportedException.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Exception;
 
 use RuntimeException;

src/amqp/src/Exception/SendChannelClosedException.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Exception;
 
 use RuntimeException;

src/amqp/src/Exception/SendChannelTimeoutException.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Exception;
 
 use RuntimeException;

src/amqp/src/Exception/TimeoutException.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Exception;
 
 use RuntimeException;

src/amqp/src/IO/IOFactory.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\IO;
 
 use Hyperf\Amqp\Exception\NotSupportedException;

src/amqp/src/IO/IOFactoryInterface.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\IO;
 
 use Hyperf\Amqp\Params;

src/amqp/src/IO/SwooleIO.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\IO;
 
 use InvalidArgumentException;

src/amqp/src/IO/SwowIO.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\IO;
 
 use Hyperf\Engine\Socket;

src/amqp/src/Listener/BeforeMainServerStartListener.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Listener;
 
 use Hyperf\Amqp\ConsumerManager;

src/amqp/src/Listener/MainWorkerStartListener.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Listener;
 
 use Doctrine\Instantiator\Instantiator;

src/amqp/src/Message/ConsumerDelayedMessageTrait.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Message;
 
 use Hyperf\Amqp\Builder\QueueBuilder;

src/amqp/src/Message/ConsumerMessage.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Message;
 
 use Hyperf\Amqp\Builder\QueueBuilder;
@@ -38,7 +39,7 @@ abstract class ConsumerMessage extends Message implements ConsumerMessageInterfa
 
     protected int $maxConsumption = 0;
 
-    protected int|float $waitTimeout = 0;
+    protected float|int $waitTimeout = 0;
 
     protected int $nums = 1;
 
@@ -113,12 +114,12 @@ abstract class ConsumerMessage extends Message implements ConsumerMessageInterfa
         return $this;
     }
 
-    public function getWaitTimeout(): int|float
+    public function getWaitTimeout(): float|int
     {
         return $this->waitTimeout;
     }
 
-    public function setWaitTimeout(int|float $timeout): static
+    public function setWaitTimeout(float|int $timeout): static
     {
         $this->waitTimeout = $timeout;
         return $this;

src/amqp/src/Message/ConsumerMessageInterface.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Message;
 
 use Hyperf\Amqp\Builder\QueueBuilder;
@@ -40,9 +41,9 @@ interface ConsumerMessageInterface extends MessageInterface
 
     public function setMaxConsumption(int $maxConsumption): static;
 
-    public function getWaitTimeout(): int|float;
+    public function getWaitTimeout(): float|int;
 
-    public function setWaitTimeout(int|float $timeout): static;
+    public function setWaitTimeout(float|int $timeout): static;
 
     public function setNums(int $nums): static;
 

src/amqp/src/Message/DynamicRpcMessage.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Message;
 
 class DynamicRpcMessage extends RpcMessage

src/amqp/src/Message/Message.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Message;
 
 use Hyperf\Amqp\Builder\ExchangeBuilder;
@@ -20,17 +21,17 @@ abstract class Message implements MessageInterface
 
     protected string $exchange = '';
 
-    protected Type|string $type = Type::TOPIC;
+    protected string|Type $type = Type::TOPIC;
 
     protected array|string $routingKey = '';
 
-    public function setType(Type|string $type): static
+    public function setType(string|Type $type): static
     {
         $this->type = $type;
         return $this;
     }
 
-    public function getType(): Type|string
+    public function getType(): string|Type
     {
         return $this->type;
     }

src/amqp/src/Message/MessageInterface.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Message;
 
 use Hyperf\Amqp\Builder\ExchangeBuilder;
@@ -22,9 +23,9 @@ interface MessageInterface
      */
     public function getPoolName(): string;
 
-    public function setType(Type|string $type);
+    public function setType(string|Type $type);
 
-    public function getType(): Type|string;
+    public function getType(): string|Type;
 
     public function setExchange(string $exchange);
 

src/amqp/src/Message/ProducerDelayedMessageTrait.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Message;
 
 use Hyperf\Amqp\Builder\ExchangeBuilder;

src/amqp/src/Message/ProducerMessage.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Message;
 
 use Hyperf\Amqp\Constants;

src/amqp/src/Message/ProducerMessageInterface.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Message;
 
 interface ProducerMessageInterface extends MessageInterface

src/amqp/src/Message/RpcMessage.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Message;
 
 use Hyperf\Amqp\Builder\QueueBuilder;

src/amqp/src/Message/RpcMessageInterface.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Message;
 
 use Hyperf\Amqp\Builder\QueueBuilder;

src/amqp/src/Message/Type.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Message;
 
 enum Type: string

src/amqp/src/Packer/Packer.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Packer;
 
 use Hyperf\Contract\PackerInterface;

src/amqp/src/Params.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp;
 
 class Params

src/amqp/src/Producer.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp;
 
 use Hyperf\Amqp\Message\ProducerMessageInterface;
@@ -64,7 +65,7 @@ class Producer extends Builder
     private function injectMessageProperty(ProducerMessageInterface $producerMessage): void
     {
         if (class_exists(AnnotationCollector::class)) {
-            /** @var null|\Hyperf\Amqp\Annotation\Producer $annotation */
+            /** @var null|Annotation\Producer $annotation */
             $annotation = AnnotationCollector::getClassAnnotation(get_class($producerMessage), Annotation\Producer::class);
             if ($annotation) {
                 $annotation->routingKey && $producerMessage->setRoutingKey($annotation->routingKey);

src/amqp/src/Result.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp;
 
 enum Result: string

src/amqp/src/RpcChannel.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp;
 
 use Hyperf\Engine\Channel;
@@ -61,7 +62,7 @@ class RpcChannel
         return $this;
     }
 
-    public function wait(int $timeout): bool|AMQPMessage
+    public function wait(int $timeout): AMQPMessage|bool
     {
         $this->channel->wait(null, false, $timeout);
 

src/amqp/src/RpcClient.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp;
 
 use Hyperf\Amqp\Builder\QueueBuilder;

src/amqp/tests/AMQPConnectionTest.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace HyperfTest\Amqp;
 
 use Hyperf\Amqp\ConnectionFactory;

src/amqp/tests/ConsumerManagerTest.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace HyperfTest\Amqp;
 
 use Hyperf\Amqp\Annotation\Consumer;

src/amqp/tests/ConsumerTest.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace HyperfTest\Amqp;
 
 use Hyperf\Amqp\ConnectionFactory;

src/amqp/tests/ExchangeBuilderTest.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace HyperfTest\Amqp;
 
 use HyperfTest\Amqp\Stub\DelayProducerStub;

src/amqp/tests/Listener/BeforeMainServerStartListenerTest.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace HyperfTest\Amqp\Listener;
 
 use Hyperf\Amqp\ConsumerManager;

src/amqp/tests/Listener/MainWorkerStartListenerTest.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace HyperfTest\Amqp\Listener;
 
 use Doctrine\Instantiator\Instantiator;

src/amqp/tests/Message/ConsumerMessageTest.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace HyperfTest\Amqp\Message;
 
 use Hyperf\Amqp\ConnectionFactory;

src/amqp/tests/Message/MessageTest.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace HyperfTest\Amqp\Message;
 
 use HyperfTest\Amqp\Stub\DemoConsumer;

src/amqp/tests/ParamsTest.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace HyperfTest\Amqp;
 
 use Hyperf\Amqp\Params;

src/amqp/tests/Stub/AMQPConnectionStub.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace HyperfTest\Amqp\Stub;
 
 use Hyperf\Amqp\AMQPConnection;

src/amqp/tests/Stub/ContainerStub.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace HyperfTest\Amqp\Stub;
 
 use Hyperf\Amqp\ConnectionFactory;

src/amqp/tests/Stub/Delay2Consumer.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace HyperfTest\Amqp\Stub;
 
 use Hyperf\Amqp\Message\ConsumerDelayedMessageTrait;

src/amqp/tests/Stub/DelayConsumer.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace HyperfTest\Amqp\Stub;
 
 use Hyperf\Amqp\Message\ConsumerDelayedMessageTrait;

src/amqp/tests/Stub/DelayProducerStub.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace HyperfTest\Amqp\Stub;
 
 use Hyperf\Amqp\Annotation\Producer;
@@ -23,7 +24,7 @@ class DelayProducerStub extends ProducerMessage
 
     protected string $exchange = 'ext.hyperf.delay';
 
-    protected Type|string $type = Type::DIRECT;
+    protected string|Type $type = Type::DIRECT;
 
     protected array|string $routingKey = '';
 

src/amqp/tests/Stub/DemoConsumer.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace HyperfTest\Amqp\Stub;
 
 use Hyperf\Amqp\Message\ConsumerMessage;

src/amqp/tests/Stub/DemoProducer.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace HyperfTest\Amqp\Stub;
 
 use Hyperf\Amqp\Message\ProducerMessage;

src/amqp/tests/Stub/NumsConsumer.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace HyperfTest\Amqp\Stub;
 
 use Hyperf\Amqp\Message\ConsumerMessage;

src/amqp/tests/Stub/QosConsumer.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace HyperfTest\Amqp\Stub;
 
 use Hyperf\Amqp\Message\ConsumerMessage;

src/async-queue/src/Annotation/AsyncQueueMessage.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue\Annotation;
 
 use Attribute;

src/async-queue/src/AnnotationJob.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue;
 
 use Hyperf\Context\ApplicationContext;

src/async-queue/src/Aspect/AsyncQueueAspect.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue\Aspect;
 
 use Hyperf\AsyncQueue\Annotation\AsyncQueueMessage;

src/async-queue/src/Command/FlushFailedMessageCommand.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue\Command;
 
 use Hyperf\AsyncQueue\Driver\DriverFactory;

src/async-queue/src/Command/InfoCommand.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue\Command;
 
 use Hyperf\AsyncQueue\Driver\DriverFactory;

src/async-queue/src/Command/ReloadFailedMessageCommand.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue\Command;
 
 use Hyperf\AsyncQueue\Driver\DriverFactory;

src/async-queue/src/ConfigProvider.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue;
 
 use Hyperf\AsyncQueue\Aspect\AsyncQueueAspect;

src/async-queue/src/Driver/ChannelConfig.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue\Driver;
 
 use Hyperf\AsyncQueue\Exception\InvalidQueueException;

src/async-queue/src/Driver/Driver.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue\Driver;
 
 use Hyperf\AsyncQueue\Event\AfterHandle;

src/async-queue/src/Driver/DriverFactory.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue\Driver;
 
 use Hyperf\AsyncQueue\Exception\InvalidDriverException;

src/async-queue/src/Driver/DriverInterface.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue\Driver;
 
 use Hyperf\AsyncQueue\JobInterface;

src/async-queue/src/Driver/RedisDriver.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue\Driver;
 
 use Hyperf\AsyncQueue\Exception\InvalidQueueException;

src/async-queue/src/Environment.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue;
 
 use Hyperf\Context\Context;

src/async-queue/src/Event/AfterHandle.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue\Event;
 
 class AfterHandle extends Event

src/async-queue/src/Event/BeforeHandle.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue\Event;
 
 class BeforeHandle extends Event

src/async-queue/src/Event/Event.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue\Event;
 
 use Hyperf\AsyncQueue\MessageInterface;

src/async-queue/src/Event/FailedHandle.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue\Event;
 
 use Hyperf\AsyncQueue\MessageInterface;

src/async-queue/src/Event/QueueLength.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue\Event;
 
 use Hyperf\AsyncQueue\Driver\DriverInterface;

src/async-queue/src/Event/RetryHandle.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue\Event;
 
 use Hyperf\AsyncQueue\MessageInterface;

src/async-queue/src/Exception/InvalidDriverException.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue\Exception;
 
 use RuntimeException;

src/async-queue/src/Exception/InvalidPackerException.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue\Exception;
 
 use RuntimeException;

src/async-queue/src/Exception/InvalidQueueException.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue\Exception;
 
 use RuntimeException;

src/async-queue/src/Functions.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue;
 
 use Hyperf\AsyncQueue\Driver\DriverFactory;

src/async-queue/src/Job.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue;
 
 use Hyperf\Contract\CompressInterface;

src/async-queue/src/JobInterface.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue;
 
 use Throwable;

src/async-queue/src/JobMessage.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue;
 
 use Hyperf\Contract\CompressInterface;

src/async-queue/src/Listener/QueueHandleListener.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue\Listener;
 
 use Hyperf\AsyncQueue\AnnotationJob;

src/async-queue/src/Listener/QueueLengthListener.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
  * @contact  group@hyperf.io
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\AsyncQueue\Listener;
 
 use Hyperf\AsyncQueue\Event\QueueLength;