diff --git a/src/RedisQueue.php b/src/RedisQueue.php index 6c8ae782..f4df046d 100644 --- a/src/RedisQueue.php +++ b/src/RedisQueue.php @@ -128,9 +128,9 @@ function ($payload, $queue, $delay) { * @param string $queue * @return \Illuminate\Contracts\Queue\Job|null */ - public function pop($queue = null) + public function pop($queue = null, $index = 0) { - return tap(parent::pop($queue), function ($result) use ($queue) { + return tap(parent::pop($queue, $index), function ($result) use ($queue) { if ($result) { $this->event($this->getQueue($queue), new JobReserved($result->getReservedJob())); }