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); + } + ); } /**