From 6c3704e9fb8eba4947a3a5f7e4a2968c0572d215 Mon Sep 17 00:00:00 2001 From: Mohamed Said Date: Mon, 4 Jan 2021 15:27:51 +0200 Subject: [PATCH] set lastPushed when executing the delayed enqueue closure not before --- src/RedisQueue.php | 14 +++++++++++--- 1 file changed, 11 insertions(+), 3 deletions(-) diff --git a/src/RedisQueue.php b/src/RedisQueue.php index 749c76f2..6c8ae782 100644 --- a/src/RedisQueue.php +++ b/src/RedisQueue.php @@ -41,9 +41,17 @@ public function readyNow($queue = null) */ public function push($job, $data = '', $queue = null) { - $this->lastPushed = $job; - - return parent::push($job, $data, $queue); + return $this->enqueueUsing( + $job, + $this->createPayload($job, $this->getQueue($queue), $data), + $queue, + null, + function ($payload, $queue) use ($job) { + $this->lastPushed = $job; + + return $this->pushRaw($payload, $queue); + } + ); } /**