diff --git a/RpcJsonp.php b/RpcJsonp.php index 2596fa3..3ab635d 100644 --- a/RpcJsonp.php +++ b/RpcJsonp.php @@ -94,7 +94,6 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa return; } $async_time = (int)Config::get('consul.async_time', 1000); - var_dump($async_time); Timer::tick($async_time, static function ($timeId) { if (env('state', 'start') == 'exit') { Timer::clear($timeId); diff --git a/RpcManager.php b/RpcManager.php index b1b6bfa..28df8bc 100644 --- a/RpcManager.php +++ b/RpcManager.php @@ -68,13 +68,16 @@ class RpcManager extends Component /** - * @throws ReflectionException * @throws Exception */ public function tick(): void { - foreach ($this->_rpc as $name => $list) { - $this->async($name); + try { + foreach ($this->_rpc as $name => $list) { + $this->async($name); + } + } catch (\Throwable $throwable) { + $this->logger()->error(error_trigger_format($throwable)); } }