改名
This commit is contained in:
@@ -27,17 +27,12 @@ class OnPipeMessage extends Callback
|
||||
public function onHandler(Server $server, int $src_worker_id, $swollen_universalize)
|
||||
{
|
||||
go(function () use ($server, $src_worker_id, $swollen_universalize) {
|
||||
try {
|
||||
match ($swollen_universalize['action'] ?? null) {
|
||||
'kafka' => $this->onKafkaWorker($swollen_universalize),
|
||||
'crontab' => $this->onCrontabWorker($swollen_universalize),
|
||||
default => $this->onMessageWorker($server, $src_worker_id, $swollen_universalize)
|
||||
};
|
||||
} catch (\Throwable $exception) {
|
||||
$this->addError($exception);
|
||||
} finally {
|
||||
fire(Event::SYSTEM_RESOURCE_RELEASES);
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
|
||||
@@ -204,7 +204,6 @@ abstract class Crontab extends BaseObject
|
||||
*/
|
||||
public function execute(): void
|
||||
{
|
||||
try {
|
||||
$redis = Snowflake::app()->getRedis();
|
||||
|
||||
$name_md5 = $this->getName();
|
||||
@@ -221,12 +220,8 @@ abstract class Crontab extends BaseObject
|
||||
'name' => $this->name,
|
||||
'response' => serialize($params)
|
||||
]));
|
||||
} catch (\Throwable $throwable) {
|
||||
logger()->addError($throwable, 'throwable');
|
||||
} finally {
|
||||
$this->after();
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
|
||||
Reference in New Issue
Block a user