fix(amqp) add attribute type (#6904)

hyperf · Jun 24, 2024 · c96e294 · c96e294
1 parent 0fdf1c2
commit c96e294
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 5 deletions.
diff --git a/src/Message/DynamicRpcMessage.php b/src/Message/DynamicRpcMessage.php
@@ -14,7 +14,7 @@
 
 class DynamicRpcMessage extends RpcMessage
 {
-    public function __construct(string $exchange, string $routingKey, $data)
+    public function __construct(string $exchange, string $routingKey, mixed $data)
     {
         $this->exchange = $exchange;
         $this->routingKey = $routingKey;

diff --git a/src/Message/RpcMessage.php b/src/Message/RpcMessage.php
@@ -20,10 +20,7 @@ abstract class RpcMessage extends Message implements RpcMessageInterface
 {
     protected string $queue = '';
 
-    /**
-     * @var mixed
-     */
-    protected $payload;
+    protected mixed $payload;
 
     public function getQueueBuilder(): QueueBuilder
     {