diff --git a/src/RpcJsonp.php b/src/RpcJsonp.php index 51dcf28..bc8bed5 100644 --- a/src/RpcJsonp.php +++ b/src/RpcJsonp.php @@ -75,8 +75,12 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa public function register(OnStart $server) { $config = Config::get('rpc'); + $agent = $this->container->get(Agent::class); - $agent->service->register($config['registry']['config']); + $data = $agent->service->register($config['registry']['config']); + if ($data->getStatusCode() != 200) { + $server->server->shutdown(); + } }