as2252258/kiri-rpc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

Revert "改名"

Browse Source 
This reverts commit fdf58326
This commit is contained in:
向林
2022-01-11 14:15:51 +08:00
parent f606c58204
commit d296b3107e
1 changed files with 10 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
RpcManager.php
+10 -6
View File
@@ -2,11 +2,11 @@
namespace Kiri\Rpc; namespace Kiri\Rpc;
use Kiri\Message\Handler\Handler;
use Kiri\Abstracts\Component; use Kiri\Abstracts\Component;
use Kiri\Consul\Agent; use Kiri\Consul\Agent;
use Kiri\Consul\Health; use Kiri\Consul\Health;
use Kiri\Kiri; use Kiri\Kiri;
use Kiri\Message\Handler\Handler;
use ReflectionException; use ReflectionException;
class RpcManager extends Component class RpcManager extends Component
@@ -115,12 +115,16 @@ class RpcManager extends Component
*/ */
public function register() public function register()
{ {
$agent = Kiri::getDi()->get(Agent::class); try {
foreach ($this->_rpc as $list) { $agent = Kiri::getDi()->get(Agent::class);
$data = $agent->service->register($list['config']); foreach ($this->_rpc as $list) {
if ($data->getStatusCode() != 200) { $data = $agent->service->register($list['config']);
return; if ($data->getStatusCode() != 200) {
return;
}
} }
} catch (\Throwable $exception) {
var_dump($exception);
} }
} }