变更

2022-05-31 11:11:12 +08:00
parent 95772e794b
commit 0ad17ae4c5
3 changed files with 18 additions and 66 deletions
@@ -128,13 +128,21 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa
    {
        Timer::clear($this->timerId);
    }
-
-
-    /**
-     * @param OnServerBeforeStart $server
-     */
+	
+	
+	/**
+	 * @param OnServerBeforeStart $server
+	 * @throws ConfigException
+	 */
    public function register(OnServerBeforeStart $server)
    {
+		$consumers = Config::get("rpc.consumers", []);
+		if (!empty($consumers)) {
+			$manager = Kiri::getDi()->get(RpcManager::class);
+			foreach ($consumers as $service => $consumer) {
+				$manager->add($service, $consumer);
+			}
+		}
        $this->manager->register();
    }