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

变更

Browse Source
This commit is contained in:
向林
2022-05-31 11:43:06 +08:00
parent 0ad17ae4c5
commit f94a8a3792
1 changed files with 10 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
RpcJsonp.php
+10 -6
View File
@@ -91,16 +91,20 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa
* @param OnBeforeShutdown $beforeShutdown * @param OnBeforeShutdown $beforeShutdown
* @return void * @return void
* @throws ContainerExceptionInterface * @throws ContainerExceptionInterface
* @throws NotFoundExceptionInterface * @throws NotFoundExceptionInterface|ConfigException
*/ */
public function onBeforeShutdown(OnBeforeShutdown $beforeShutdown): void public function onBeforeShutdown(OnBeforeShutdown $beforeShutdown): void
{ {
$doneList = $this->manager->doneList();
$agent = $this->container->get(Agent::class); $agent = $this->container->get(Agent::class);
foreach ($doneList as $value) { $value = Config::get("rpc.consul", []);
$agent->service->deregister($value['config']['ID']); if (empty($value)) {
$agent->checks->deregister($value['config']['Check']['CheckId']); return;
} }
$this->logger->debug("disconnect consul.");
$agent->service->deregister($value['ID']);
$agent->checks->deregister($value['Check']['CheckId']);
} }