From 5cfe9bab274190a618d30ff7c2f92bbeb72a5846 Mon Sep 17 00:00:00 2001 From: zyimm Date: Tue, 17 Oct 2023 11:41:12 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=E5=BC=82=E5=B8=B8?= =?UTF-8?q?=E7=B1=BB=E5=9E=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/producer/Producer.php | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/producer/Producer.php b/src/producer/Producer.php index 75dbc95..a117d5b 100644 --- a/src/producer/Producer.php +++ b/src/producer/Producer.php @@ -8,6 +8,7 @@ use GuzzleHttp\Pool; use GuzzleHttp\Psr7\Request; use GuzzleHttp\Psr7\Response; use Psr\Http\Message\ResponseInterface; +use Throwable; use tm\xls\rocketMq\thinkphp\connection\Connection; class Producer @@ -52,7 +53,7 @@ class Producer $index => $response->getBody()->getContents() ]; }, - 'rejected' => function (RequestException $reason, $index) { + 'rejected' => function (Throwable $reason, $index) { //todo 失败 return [ $index => $reason->getMessage()