zyimm/rocket-mq-client-thinkphp
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

消息体支持原始json对象

Browse Source
This commit is contained in:
zyimm 2023-08-20 13:52:33 +08:00
parent ff5d7f4e3c
commit 7699a7d16d
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/consumer/message/Message.php
View File

@ -20,11 +20,11 @@ class Message
} }
/** /**
* @param string $message_body * @param mixed $message_body
*/ */
public function setMessageBody(string $message_body): void public function setMessageBody($message_body): void
{ {
$this->messageBody = json_decode($message_body, true); $this->messageBody = is_array($message_body) ? $message_body : json_decode($message_body, true);
} }
/** /**
@ -68,7 +68,7 @@ class Message
} }
/** /**
* @param string $messageId * @param string $messageId
*/ */
public function setMessageId(string $messageId): void public function setMessageId(string $messageId): void
{ {