modify
This commit is contained in:
@@ -90,7 +90,7 @@ class Zookeeper extends Process
|
|||||||
|
|
||||||
$startTime = time();
|
$startTime = time();
|
||||||
|
|
||||||
$range = $redis->zRangeByScore(Producer::CRONTAB_KEY, '0', (string)$startTime);
|
$range = $redis->zRemRangeByScore(Producer::CRONTAB_KEY, '0', (string)$startTime);
|
||||||
var_dump($startTime, $range);
|
var_dump($startTime, $range);
|
||||||
// $redis->zRemRangeByScore(Producer::CRONTAB_KEY, '0', (string)$startTime);
|
// $redis->zRemRangeByScore(Producer::CRONTAB_KEY, '0', (string)$startTime);
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user