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

src/AMQPConnection.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp;
 
 use Hyperf\Amqp\Exception\LoopBrokenException;

src/Annotation/Consumer.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Annotation;
 
 use Attribute;

src/Annotation/Producer.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Annotation;
 
 use Attribute;

src/Builder.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp;
 
 use Hyperf\Amqp\Message\MessageInterface;

src/Builder/Builder.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Builder;
 
 use PhpAmqpLib\Wire\AMQPTable;

src/Builder/ExchangeBuilder.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Builder;
 
 use Hyperf\Amqp\Message\Type;
@@ -32,7 +33,7 @@ public function setExchange(string $exchange): static
         return $this;
     }
 
-    public function getType(): Type|string
+    public function getType(): string|Type
     {
         return $this->type;
     }
@@ -42,7 +43,7 @@ public function getTypeString(): string
         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/Builder/QueueBuilder.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Builder;
 
 use PhpAmqpLib\Wire\AMQPTable;

src/ConfigProvider.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp;
 
 use Hyperf\Amqp\Listener\BeforeMainServerStartListener;

src/ConnectionFactory.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp;
 
 use Hyperf\Amqp\Exception\NotSupportedException;

src/Constants.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp;
 
 class Constants

src/Consumer.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp;
 
 use Hyperf\Amqp\Event\AfterConsume;

src/ConsumerFactory.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp;
 
 use Hyperf\Contract\StdoutLoggerInterface;

src/ConsumerManager.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp;
 
 use Hyperf\Amqp\Annotation\Consumer as ConsumerAnnotation;

src/Event/AfterConsume.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Event;
 
 use Hyperf\Amqp\Message\ConsumerMessageInterface;

src/Event/BeforeConsume.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Event;
 
 use Hyperf\Amqp\Message\ConsumerMessageInterface;

src/Event/ConsumeEvent.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Event;
 
 use Hyperf\Amqp\Message\ConsumerMessageInterface;

src/Event/FailToConsume.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Event;
 
 use Hyperf\Amqp\Message\ConsumerMessageInterface;

src/Event/WaitTimeout.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Event;
 
 class WaitTimeout extends ConsumeEvent

src/Exception/LoopBrokenException.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Exception;
 
 use RuntimeException;

src/Exception/MaxConsumptionException.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Exception;
 
 use Exception;

src/Exception/MessageException.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Exception;
 
 use Exception;

src/Exception/NotSupportedException.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Exception;
 
 use RuntimeException;

src/Exception/SendChannelClosedException.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Exception;
 
 use RuntimeException;

src/Exception/SendChannelTimeoutException.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Exception;
 
 use RuntimeException;

src/Exception/TimeoutException.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Exception;
 
 use RuntimeException;

src/IO/IOFactory.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\IO;
 
 use Hyperf\Amqp\Exception\NotSupportedException;

src/IO/IOFactoryInterface.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\IO;
 
 use Hyperf\Amqp\Params;

src/IO/SwooleIO.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\IO;
 
 use InvalidArgumentException;

src/IO/SwowIO.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\IO;
 
 use Hyperf\Engine\Socket;

src/Listener/BeforeMainServerStartListener.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Listener;
 
 use Hyperf\Amqp\ConsumerManager;

src/Listener/MainWorkerStartListener.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Listener;
 
 use Doctrine\Instantiator\Instantiator;

src/Message/ConsumerDelayedMessageTrait.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Message;
 
 use Hyperf\Amqp\Builder\QueueBuilder;

src/Message/ConsumerMessage.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @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 @@ public function setMaxConsumption(int $maxConsumption): static
         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/Message/ConsumerMessageInterface.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Message;
 
 use Hyperf\Amqp\Builder\QueueBuilder;
@@ -40,9 +41,9 @@ public function getMaxConsumption(): int;
 
     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/Message/DynamicRpcMessage.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Message;
 
 class DynamicRpcMessage extends RpcMessage

src/Message/Message.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @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/Message/MessageInterface.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Message;
 
 use Hyperf\Amqp\Builder\ExchangeBuilder;
@@ -22,9 +23,9 @@ public function setPoolName(string $name);
      */
     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/Message/ProducerDelayedMessageTrait.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Message;
 
 use Hyperf\Amqp\Builder\ExchangeBuilder;

src/Message/ProducerMessage.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 namespace Hyperf\Amqp\Message;
 
 use Hyperf\Amqp\Constants;