modify plugin name

2022-06-08 14:27:49 +08:00
parent 188742360e
commit b495927099
1 changed files with 2 additions and 1 deletions
@@ -95,9 +95,10 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa
     */
    public function onBeforeShutdown(OnBeforeShutdown $beforeShutdown): void
    {
-		if ($beforeShutdown->server->worker_id != 0) {
+		if (env('environmental_workerId') != 0) {
 			return;
 		}
+
        $agent = $this->container->get(Agent::class);
 	    $value = Config::get("rpc.consul", []);
 		if (empty($value)) {