|
|
@@ -139,7 +139,7 @@ class Queue
|
|
|
*/
|
|
|
public function consumeTask() {
|
|
|
// 从缓存获取所有小于当前时间的队列
|
|
|
- $allTasks = Yii::$app->redis->zRangeByScore(self::REDIS_LIST_KEY, 0, Date::nowTime());
|
|
|
+ $allTasks = Yii::$app->redis->zrangebyscore(self::REDIS_LIST_KEY, 0, Date::nowTime());
|
|
|
// 循环所有任务
|
|
|
foreach ($allTasks as $taskId){
|
|
|
// 清除当前任务队列
|