diff --git a/src/producer/Producer.php b/src/producer/Producer.php
index eff313d..f617617 100644
--- a/src/producer/Producer.php
+++ b/src/producer/Producer.php
@@ -12,6 +12,8 @@ use tm\xls\rocketMq\thinkphp\connection\Connection;
 
 class Producer
 {
+    const TYPE = 1;
+
     private $connection;
 
     public function __construct(Connection $connection)
@@ -40,7 +42,7 @@ class Producer
             }
         };
         //连接池
-        $pool = new Pool($this->connection->getClient(), $requests($data), [
+        $pool    = new Pool($this->connection->getClient(), $requests($data), [
             'concurrency' => 5,
             'fulfilled'   => function (Response $response, $index) {
                 //todo 成功
@@ -71,9 +73,10 @@ class Producer
 
     private function buildMessage(array $data): array
     {
-        $data['backUrl']     = $this->connection->config->getBackUrl();
-        $data['messageBody'] = $data['body'] ?? '';
-        $data['messageBody'] = json_encode($data['messageBody']);
+        $data['backUrl']      = $this->connection->config->getBackUrl();
+        $data['messageBody']  = $data['body'] ?? '';
+        $data['messageBody']  = json_encode($data['messageBody']);
+        $data['consumerType'] = static::TYPE;
         unset($data['body']);
         return $data;
     }