modify
This commit is contained in:
@@ -32,8 +32,8 @@ class Consumer extends Process
|
|||||||
while (true) {
|
while (true) {
|
||||||
[$value, $startTime] = swoole_unserialize($process->read());
|
[$value, $startTime] = swoole_unserialize($process->read());
|
||||||
|
|
||||||
$crontab = $redis->get('crontab:' . md5($value));
|
$crontab = $redis->get($value);
|
||||||
$redis->del('crontab:' . md5($value));
|
$redis->del($value);
|
||||||
if (empty($crontab) || !($crontab = swoole_unserialize($crontab))) {
|
if (empty($crontab) || !($crontab = swoole_unserialize($crontab))) {
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user