改名
This commit is contained in:
@@ -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) {
|
||||
if ($handler->isRecover() !== 999) {
|
||||
return;
|
||||
|
||||
@@ -86,7 +86,7 @@ class Zookeeper extends Process
|
||||
if (empty($handler = $redis->get('crontab:' . $value))) {
|
||||
return;
|
||||
}
|
||||
$params['handler'] = $handler;
|
||||
$params['handler'] = swoole_unserialize($handler);
|
||||
|
||||
$this->server->sendMessage($params, $this->getWorker());
|
||||
} catch (Throwable $exception) {
|
||||
|
||||
Reference in New Issue
Block a user