diff --git a/Handler/OnServerWorker.php b/Handler/OnServerWorker.php index 84d449e..6523cfa 100644 --- a/Handler/OnServerWorker.php +++ b/Handler/OnServerWorker.php @@ -77,7 +77,7 @@ class OnServerWorker extends Kiri\Server\Abstracts\Server */ protected function processName(Server $server, string $prefix): void { - Kiri::setProcessName(sprintf($prefix . ' AbstractProcess[%d].%d', $server->worker_pid, $server->worker_id)); + Kiri::setProcessName(sprintf($prefix . ' Process[%d].%d', $server->worker_pid, $server->worker_id)); } diff --git a/Processes/TraitProcess.php b/Processes/TraitProcess.php index 1fb16af..3a3c535 100644 --- a/Processes/TraitProcess.php +++ b/Processes/TraitProcess.php @@ -22,21 +22,13 @@ trait TraitProcess */ public function addProcess(string|array|AbstractProcess $class): void { - if (!is_array($class)) { - $class = [$class]; - } + if (!is_array($class)) $class = [$class]; foreach ($class as $name) { - if (is_string($name)) { - $name = Kiri::getDi()->get($name); - } + if (is_string($name)) $name = Kiri::getDi()->get($name); if (isset($this->_process[$name->getName()])) { throw new Exception('AbstractProcess(' . $name->getName() . ') is exists.'); } - $process = $this->genProcess($name); - if ($name->isEnableQueue()) { - $process->useQueue(); - } - $this->_process[$name->getName()] = $process; + $this->_process[$name->getName()] = $this->genProcess($name); } }