modify

2021-04-16 01:05:10 +08:00
parent 56b5fc2f78
commit e6cf428a2e
1 changed files with 2 additions and 1 deletions
@@ -32,7 +32,8 @@ class Producer extends Component
            throw new Exception('Cache key ' . self::CRONTAB_KEY . ' types error.');
        }

-        $redis->del('stop:crontab:' . $name, 120);
+        $redis->setex('stop:crontab:' . $name, 120, 1);
+        $redis->zRem(static::CRONTAB_KEY, $name);
        if ($redis->exists('crontab:' . $name)) {
            $redis->del('crontab:' . $name);
        }