This commit is contained in:
as2252258@163.com
2021-04-24 20:06:21 +08:00
parent c3a3d378ac
commit 871dcaa97a
2 changed files with 2 additions and 2 deletions
+1 -1
View File
@@ -47,7 +47,7 @@ class OnPipeMessage extends Callback
throw new Exception('unknown handler');
}
/** @var Crontab $handler */
$handler = swoole_unserialize($message['handler']);
$handler = $message['handler'];
defer(function () use ($handler) {
$return = $handler->isRecover();
if ($return === 999) {
+1 -1
View File
@@ -85,7 +85,7 @@ class Zookeeper extends Process
if (empty($handler = $redis->get('crontab:' . $value))) {
return;
}
$params['handler'] = $handler;
$params['handler'] = unserialize($handler);
$this->server->sendMessage($params, $this->getWorker());
} catch (Throwable $exception) {