diff --git a/src/Illuminate/Queue/Jobs/SyncJob.php b/src/Illuminate/Queue/Jobs/SyncJob.php index fe7df1798540..efc076e3264a 100755 --- 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 index de8db22a7496..36516dbcd9ee 100755 --- 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); } /**