laravel
diff --git a/‎src/Illuminate/Queue/Queue.php
Copy file name to clipboardExpand all lines: src/Illuminate/Queue/Queue.php
+1-1Lines changed: 1 addition & 1 deletion b/‎src/Illuminate/Queue/Queue.php
Copy file name to clipboardExpand all lines: src/Illuminate/Queue/Queue.php
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/‎src/Illuminate/Queue/SyncQueue.php
Copy file name to clipboardExpand all lines: src/Illuminate/Queue/SyncQueue.php
+22Lines changed: 22 additions & 0 deletions b/‎src/Illuminate/Queue/SyncQueue.php
Copy file name to clipboardExpand all lines: src/Illuminate/Queue/SyncQueue.php
+22Lines changed: 22 additions & 0 deletions
diff --git a/‎tests/Queue/QueueSyncQueueTest.php
Copy file name to clipboardExpand all lines: tests/Queue/QueueSyncQueueTest.php
+48Lines changed: 48 additions & 0 deletions b/‎tests/Queue/QueueSyncQueueTest.php
Copy file name to clipboardExpand all lines: tests/Queue/QueueSyncQueueTest.php
+48Lines changed: 48 additions & 0 deletions
@@ -326,7 +326,7 @@ function () use ($payload, $queue, $delay, $callback, $job) {
      */
     protected function shouldDispatchAfterCommit($job)
     {
-        if (is_object($job) && $job instanceof ShouldQueueAfterCommit) {
+        if ($job instanceof ShouldQueueAfterCommit) {
             return true;
         }
 
 
@@ -34,6 +34,28 @@ public function size($queue = null)
      * @throws \Throwable
      */
     public function push($job, $data = '', $queue = null)
+    {
+        if ($this->shouldDispatchAfterCommit($job) &&
+            $this->container->bound('db.transactions')) {
+            return $this->container->make('db.transactions')->addCallback(
+                fn () => $this->executeJob($job, $data, $queue)
+            );
+        }
+
+        return $this->executeJob($job, $data, $queue);
+    }
+
+    /**
+     * Execute a given job synchronously.
+     *
+     * @param  string  $job
+     * @param  mixed  $data
+     * @param  string|null  $queue
+     * @return int
+     *
+     * @throws \Throwable
+     */
+    protected function executeJob($job, $data = '', $queue = null)
     {
         $queueJob = $this->resolveJob($this->createPayload($job, $queue, $data), $queue);
 
 
@@ -7,6 +7,8 @@
 use Illuminate\Contracts\Events\Dispatcher;
 use Illuminate\Contracts\Queue\QueueableEntity;
 use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Contracts\Queue\ShouldQueueAfterCommit;
+use Illuminate\Database\DatabaseTransactionsManager;
 use Illuminate\Queue\InteractsWithQueue;
 use Illuminate\Queue\Jobs\SyncJob;
 use Illuminate\Queue\SyncQueue;
@@ -77,6 +79,32 @@ public function testCreatesPayloadObject()
             $this->assertSame('extraValue', $e->getMessage());
         }
     }
+
+    public function testItAddsATransactionCallbackForAfterCommitJobs()
+    {
+        $sync = new SyncQueue;
+        $container = new Container;
+        $container->bind(\Illuminate\Contracts\Container\Container::class, \Illuminate\Container\Container::class);
+        $transactionManager = m::mock(DatabaseTransactionsManager::class);
+        $transactionManager->shouldReceive('addCallback')->once()->andReturn(null);
+        $container->instance('db.transactions', $transactionManager);
+
+        $sync->setContainer($container);
+        $sync->push(new SyncQueueAfterCommitJob());
+    }
+
+    public function testItAddsATransactionCallbackForInterfaceBasedAfterCommitJobs()
+    {
+        $sync = new SyncQueue;
+        $container = new Container;
+        $container->bind(\Illuminate\Contracts\Container\Container::class, \Illuminate\Container\Container::class);
+        $transactionManager = m::mock(DatabaseTransactionsManager::class);
+        $transactionManager->shouldReceive('addCallback')->once()->andReturn(null);
+        $container->instance('db.transactions', $transactionManager);
+
+        $sync->setContainer($container);
+        $sync->push(new SyncQueueAfterCommitInterfaceJob());
+    }
 }
 
 class SyncQueueTestEntity implements QueueableEntity
@@ -134,3 +162,23 @@ public function getValueFromJob($key)
         return $payload['data'][$key] ?? null;
     }
 }
+
+class SyncQueueAfterCommitJob
+{
+    use InteractsWithQueue;
+
+    public $afterCommit = true;
+
+    public function handle()
+    {
+    }
+}
+
+class SyncQueueAfterCommitInterfaceJob implements ShouldQueueAfterCommit
+{
+    use InteractsWithQueue;
+
+    public function handle()
+    {
+    }
+}
Original file line number	Diff line number	Diff line change
`@@ -326,7 +326,7 @@ function () use ($payload, $queue, $delay, $callback, $job) {`
`326`	`326`	`*/`
`327`	`327`	`protected function shouldDispatchAfterCommit($job)`
`328`	`328`	`{`
`329`		`- if (is_object($job) && $job instanceof ShouldQueueAfterCommit) {`
	`329`	`+ if ($job instanceof ShouldQueueAfterCommit) {`
`330`	`330`	`return true;`
`331`	`331`	`}`
`332`	`332`