Fix missing queue name on sync job

laravel · Sep 9, 2016 · 30bda12 · 30bda12
1 parent 32dcea9
commit 30bda12
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 4 deletions.
diff --git a/src/Illuminate/Queue/Jobs/SyncJob.php b/src/Illuminate/Queue/Jobs/SyncJob.php
@@ -26,12 +26,14 @@ class SyncJob extends Job implements JobContract
      *
      * @param  \Illuminate\Container\Container  $container
      * @param  string  $payload
+     * @param  string  $queue
      * @return void
      */
-    public function __construct(Container $container, $payload)
+    public function __construct(Container $container, $payload, $queue)
     {
         $this->payload = $payload;
         $this->container = $container;
+        $this->queue = $queue;
     }
 
     /**

diff --git a/src/Illuminate/Queue/SyncQueue.php b/src/Illuminate/Queue/SyncQueue.php
@@ -21,7 +21,7 @@ class SyncQueue extends Queue implements QueueContract
      */
     public function push($job, $data = '', $queue = null)
     {
-        $queueJob = $this->resolveJob($this->createPayload($job, $data, $queue));
+        $queueJob = $this->resolveJob($this->createPayload($job, $data, $queue), $queue);
 
         try {
             $queueJob->fire();
@@ -82,11 +82,12 @@ public function pop($queue = null)
      * Resolve a Sync job instance.
      *
      * @param  string  $payload
+     * @param  string  $queue
      * @return \Illuminate\Queue\Jobs\SyncJob
      */
-    protected function resolveJob($payload)
+    protected function resolveJob($payload, $queue)
     {
-        return new SyncJob($this->container, $payload);
+        return new SyncJob($this->container, $payload, $queue);
     }
 
     /**