From d296b3107e6d441ce8a0e560cc4bf69b81046622 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=90=91=E6=9E=97?= Date: Tue, 11 Jan 2022 14:15:51 +0800 Subject: [PATCH] =?UTF-8?q?Revert=20"=E6=94=B9=E5=90=8D"?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit This reverts commit fdf58326 --- RpcManager.php | 16 ++++++++++------ 1 file changed, 10 insertions(+), 6 deletions(-) diff --git a/RpcManager.php b/RpcManager.php index 41a925a..9d297bc 100644 --- a/RpcManager.php +++ b/RpcManager.php @@ -2,11 +2,11 @@ namespace Kiri\Rpc; -use Kiri\Message\Handler\Handler; use Kiri\Abstracts\Component; use Kiri\Consul\Agent; use Kiri\Consul\Health; use Kiri\Kiri; +use Kiri\Message\Handler\Handler; use ReflectionException; class RpcManager extends Component @@ -115,12 +115,16 @@ class RpcManager extends Component */ public function register() { - $agent = Kiri::getDi()->get(Agent::class); - foreach ($this->_rpc as $list) { - $data = $agent->service->register($list['config']); - if ($data->getStatusCode() != 200) { - return; + try { + $agent = Kiri::getDi()->get(Agent::class); + foreach ($this->_rpc as $list) { + $data = $agent->service->register($list['config']); + if ($data->getStatusCode() != 200) { + return; + } } + } catch (\Throwable $exception) { + var_dump($exception); } }