as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

改名

Browse Source
This commit is contained in:
Mr·x
2021-04-15 18:21:20 +08:00
parent adcfc39fb8
commit 52b96fd700
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
HttpServer/Events/OnPipeMessage.php
+3 -4
View File
@@ -47,13 +47,12 @@ class OnPipeMessage extends Callback
*/ */
private function onCrontabWorker(array $message): string private function onCrontabWorker(array $message): string
{ {
var_dump($message);
/** @var Crontab $crontab */
$crontab = $message['handler'] ?? null;
if (!isset($message['handler'])) { if (!isset($message['handler'])) {
throw new Exception('unknown handler'); throw new Exception('unknown handler');
} }
$crontab = swoole_unserialize($crontab['handler']);
/** @var Crontab $crontab */
$crontab = swoole_unserialize($message['handler']);
$crontab->increment()->execute(); $crontab->increment()->execute();
return 'success'; return 'success';
} }