diff --git a/Annotation/Route/RpcProducer.php b/Annotation/Route/RpcProducer.php deleted file mode 100644 index cf0bfd82..00000000 --- a/Annotation/Route/RpcProducer.php +++ /dev/null @@ -1,57 +0,0 @@ -getRouter(); - $cmd = $this->cmd; - $callback = function (Actuator $actuator) use ($cmd, $class, $method) { - $actuator->addListener($cmd, $class::class . '@' . $method); - }; - $router->addRpcService($this->port, $callback); - return $router; - } - - -} diff --git a/Annotation/Rpc/RpcClient.php b/Annotation/Rpc/RpcClient.php deleted file mode 100644 index cebec17c..00000000 --- a/Annotation/Rpc/RpcClient.php +++ /dev/null @@ -1,55 +0,0 @@ -config = ['port' => $port, 'mode' => $mode, 'timeout' => $timeout]; - } - - - /** - * @param mixed $class - * @param mixed $method - * @return bool - * @throws Exception - */ - public function execute(mixed $class, mixed $method = ''): bool - { - $rpc = Kiri::app()->getRpc(); - $rpc->addProducer($this->cmd, [$class, $method], $this->config); - - return true; - } - - -}