From f94a8a3792d879ed345e7c1419e5d5687f178135 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=90=91=E6=9E=97?= <as2252258@163.com>
Date: Tue, 31 May 2022 11:43:06 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8F=98=E6=9B=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 RpcJsonp.php | 16 ++++++++++------
 1 file changed, 10 insertions(+), 6 deletions(-)

diff --git a/RpcJsonp.php b/RpcJsonp.php
index 382d9ad..83e9a17 100644
--- a/RpcJsonp.php
+++ b/RpcJsonp.php
@@ -91,16 +91,20 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa
      * @param OnBeforeShutdown $beforeShutdown
      * @return void
      * @throws ContainerExceptionInterface
-     * @throws NotFoundExceptionInterface
+     * @throws NotFoundExceptionInterface|ConfigException
      */
     public function onBeforeShutdown(OnBeforeShutdown $beforeShutdown): void
     {
-        $doneList = $this->manager->doneList();
         $agent = $this->container->get(Agent::class);
-        foreach ($doneList as $value) {
-            $agent->service->deregister($value['config']['ID']);
-            $agent->checks->deregister($value['config']['Check']['CheckId']);
-        }
+	    $value = Config::get("rpc.consul", []);
+		if (empty($value)) {
+			return;
+		}
+		
+		$this->logger->debug("disconnect consul.");
+		
+	    $agent->service->deregister($value['ID']);
+	    $agent->checks->deregister($value['Check']['CheckId']);
     }