This commit is contained in:
2021-03-01 15:56:57 +08:00
parent 141469929e
commit 251efd62f1
+5 -8
View File
@@ -42,9 +42,7 @@ abstract class Callback extends HttpService
$logger->write($this->_MESSAGE[$message] . $worker_id); $logger->write($this->_MESSAGE[$message] . $worker_id);
$logger->clear(); $logger->clear();
$event = Snowflake::app()->getEvent(); $this->eventNotify($message);
$event->offName(Event::SYSTEM_RESOURCE_RELEASES);
$this->eventNotify($message, $event);
} catch (\Throwable $exception) { } catch (\Throwable $exception) {
$this->addError($exception); $this->addError($exception);
} }
@@ -65,20 +63,19 @@ abstract class Callback extends HttpService
/** /**
* @param $message * @param $message
* @param Event $event
* @throws Exception * @throws Exception
*/ */
private function eventNotify($message, Event $event) private function eventNotify($message)
{ {
switch ($message) { switch ($message) {
case self::EVENT_ERROR: case self::EVENT_ERROR:
$event->trigger(Event::SERVER_WORKER_ERROR); fire(Event::SERVER_WORKER_ERROR);
break; break;
case self::EVENT_EXIT: case self::EVENT_EXIT:
$event->trigger(Event::SERVER_WORKER_EXIT); fire(Event::SERVER_WORKER_EXIT);
break; break;
case self::EVENT_STOP: case self::EVENT_STOP:
$event->trigger(Event::SERVER_WORKER_STOP); fire(Event::SERVER_WORKER_STOP);
break; break;
} }
} }