支持消息id

src/consumer/Consumer.php

@@ -18,6 +18,7 @@ class Consumer
         $this->message->setMessageBody($data['messageBody'] ?? '');
         $this->message->setTopic($data['topic'] ?? '');
         $this->message->setTag($data['tag'] ?? '');
+        $this->message->setMessageId($data['messageId'] ?? '');
     }
 
 

src/consumer/message/Message.php

@@ -4,6 +4,7 @@ namespace tm\xls\rocketMq\thinkphp\consumer\message;
 
 class Message
 {
+    private $messageId;
     private $messageBody;
 
     private $tag;
@@ -57,4 +58,20 @@ class Message
     {
         $this->topic = $topic;
     }
+
+    /**
+     * @return mixed
+     */
+    public function getMessageId()
+    {
+        return $this->messageId;
+    }
+
+    /**
+     * @param string  $messageId
+     */
+    public function setMessageId(string $messageId): void
+    {
+        $this->messageId = $messageId;
+    }
 }