diff --git a/LuaScripts.php b/LuaScripts.php index 4ce6acec..93ac0478 100644 --- a/LuaScripts.php +++ b/LuaScripts.php @@ -97,7 +97,7 @@ public static function migrateExpiredJobs() end end -return true +return val LUA; } } diff --git a/RedisQueue.php b/RedisQueue.php index a81c8d19..2c0037ac 100644 --- a/RedisQueue.php +++ b/RedisQueue.php @@ -174,11 +174,11 @@ protected function migrate($queue) * * @param string $from * @param string $to - * @return void + * @return array */ public function migrateExpiredJobs($from, $to) { - $this->getConnection()->eval( + return $this->getConnection()->eval( LuaScripts::migrateExpiredJobs(), 2, $from, $to, $this->currentTime() ); }