This commit is contained in:
2021-10-29 14:08:17 +08:00
parent 7d3e810992
commit 1ec84d0fb3
+3 -2
View File
@@ -73,14 +73,15 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa
/** /**
* @throws ConfigException * @throws ConfigException
*/ */
public function register(Server $server) public function register(OnStart $server)
{ {
var_dump($server);
$config = Config::get('rpc'); $config = Config::get('rpc');
$agent = Kiri::getDi()->get(Agent::class); $agent = Kiri::getDi()->get(Agent::class);
$data = $agent->service->register($config['registry']['config']); $data = $agent->service->register($config['registry']['config']);
if ($data->getStatusCode() != 200) { if ($data->getStatusCode() != 200) {
$server->shutdown(); $server->server->shutdown();
} }
} }