use enqueueUsing when pushing delayed jobs (#939)

laravel · Dec 1, 2020 · f69fd50 · f69fd50
1 parent 4e21779
commit f69fd50
Showing 1 changed file with 14 additions and 0 deletions.
diff --git a/src/RedisQueue.php b/src/RedisQueue.php
@@ -95,6 +95,20 @@ public function later($delay, $job, $data = '', $queue = null)
     {
         $payload = (new JobPayload($this->createPayload($job, $queue, $data)))->prepare($job)->value;
 
+        if (method_exists($this, 'enqueueUsing')) {
+            return $this->enqueueUsing(
+                $job,
+                $payload,
+                $queue,
+                $delay,
+                function ($payload, $queue, $delay) {
+                    return tap(parent::laterRaw($delay, $payload, $queue), function () use ($payload, $queue) {
+                        $this->event($this->getQueue($queue), new JobPushed($payload));
+                    });
+                }
+            );
+        }
+
         return tap(parent::laterRaw($delay, $payload, $queue), function () use ($payload, $queue) {
             $this->event($this->getQueue($queue), new JobPushed($payload));
         });