formatting

Author: taylorotwell

src/Illuminate/Queue/Events/JobQueued.php

@@ -5,25 +5,38 @@
 class JobQueued
 {
     /**
+     * The connection name.
+     *
+     * @var string
+     */
+    public $connectionName;
+
+    /**
+     * The job ID.
+     *
      * @var string|int|null
      */
-    public $jobId;
+    public $id;
 
     /**
-     * @var string|object
+     * The job instance.
+     *
+     * @var \Closure|string|object
      */
     public $job;
 
     /**
-     * JobQueued constructor.
+     * Create a new event instance.
      *
-     * @param  string|int|null  $jobId
+     * @param  string  $connectionName
+     * @param  string|int|null  $id
      * @param  \Closure|string|object  $job
      * @return void
      */
-    public function __construct($jobId, $job)
+    public function __construct($connectionName, $id, $job)
     {
-        $this->jobId = $jobId;
+        $this->connectionName = $connectionName;
+        $this->id = $id;
         $this->job = $job;
     }
 }

src/Illuminate/Queue/Queue.php

@@ -317,6 +317,20 @@ protected function shouldDispatchAfterCommit($job)
         return false;
     }
 
+    /**
+     * Raise the job queued event.
+     *
+     * @param  string|int|null  $jobId
+     * @param  \Closure|string|object  $job
+     * @return void
+     */
+    protected function raiseJobQueuedEvent($jobId, $job)
+    {
+        if ($this->container->bound('events')) {
+            $this->container['events']->dispatch(new JobQueued($this->connectionName, $jobId, $job));
+        }
+    }
+
     /**
      * Get the connection name for the queue.
      *
@@ -350,18 +364,4 @@ public function setContainer(Container $container)
     {
         $this->container = $container;
     }
-
-    /**
-     * Raise the job queued event.
-     *
-     * @param  string|int|null  $jobId
-     * @param  \Closure|string|object  $job
-     * @return void
-     */
-    protected function raiseJobQueuedEvent($jobId, $job)
-    {
-        if ($this->container->bound('events')) {
-            $this->container['events']->dispatch(new JobQueued($jobId, $job));
-        }
-    }
 }

tests/Queue/RedisQueueIntegrationTest.php

@@ -477,7 +477,7 @@ public function testPushJobQueuedEvent($driver)
         $events = m::mock(Dispatcher::class);
         $events->shouldReceive('dispatch')->withArgs(function (JobQueued $jobQueued) {
             $this->assertInstanceOf(RedisQueueIntegrationTestJob::class, $jobQueued->job);
-            $this->assertIsString(RedisQueueIntegrationTestJob::class, $jobQueued->jobId);
+            $this->assertIsString(RedisQueueIntegrationTestJob::class, $jobQueued->id);
 
             return true;
         })->andReturnNull()->once();