From c96e294e99e68113ed3e237db8f976308ee42ba7 Mon Sep 17 00:00:00 2001
From: IronSmith <126216752+srkj2018@users.noreply.github.com>
Date: Mon, 24 Jun 2024 09:53:39 +0800
Subject: [PATCH] fix(amqp) add attribute type (#6904)

---
 src/Message/DynamicRpcMessage.php | 2 +-
 src/Message/RpcMessage.php        | 5 +----
 2 files changed, 2 insertions(+), 5 deletions(-)

diff --git a/src/Message/DynamicRpcMessage.php b/src/Message/DynamicRpcMessage.php
index cd3da87..10ee607 100644
--- 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
index bed559d..3d4315a 100644
--- 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
     {