diff --git a/src/producer/Producer.php b/src/producer/Producer.php index f617617..8365e0a 100644 --- a/src/producer/Producer.php +++ b/src/producer/Producer.php @@ -38,7 +38,7 @@ class Producer } else { $uri = $uri.'/rocketmq/producer/send'; } - yield new Request('POST', $uri, [], $this->buildMessage($item)); + yield new Request('POST', $uri, [], json_encode($this->buildMessage($item))); } }; //连接池