Deferred queue

config/queue.php

@@ -72,6 +72,18 @@
             'after_commit' => false,
         ],
 
+        'deferred' => [
+            'driver' => 'deferred',
+        ],
+
+        'failover' => [
+            'driver' => 'failover',
+            'connections' => [
+                'database',
+                'deferred',
+            ],
+        ],
+
     ],
 
     /*

src/Illuminate/Queue/Connectors/DeferredConnector.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace Illuminate\Queue\Connectors;
+
+use Illuminate\Queue\DeferredQueue;
+
+class DeferredConnector implements ConnectorInterface
+{
+    /**
+     * Establish a queue connection.
+     *
+     * @return \Illuminate\Contracts\Queue\Queue
+     */
+    public function connect(array $config)
+    {
+        return new DeferredQueue($config['after_commit'] ?? null);
+    }
+}

src/Illuminate/Queue/DeferredQueue.php

@@ -0,0 +1,23 @@
+<?php
+
+namespace Illuminate\Queue;
+
+use Illuminate\Contracts\Queue\Job;
+
+class DeferredQueue extends SyncQueue
+{
+    /**
+     * Push a new job onto the queue.
+     *
+     * @param  string  $job
+     * @param  mixed  $data
+     * @param  string|null  $queue
+     * @return mixed
+     *
+     * @throws \Throwable
+     */
+    public function push($job, $data = '', $queue = null)
+    {
+        return \Illuminate\Support\defer(fn () => parent::push($job, $data, $queue));
+    }
+}

src/Illuminate/Queue/QueueServiceProvider.php

@@ -8,6 +8,7 @@
 use Illuminate\Contracts\Support\DeferrableProvider;
 use Illuminate\Queue\Connectors\BeanstalkdConnector;
 use Illuminate\Queue\Connectors\DatabaseConnector;
+use Illuminate\Queue\Connectors\DeferredConnector;
 use Illuminate\Queue\Connectors\FailoverConnector;
 use Illuminate\Queue\Connectors\NullConnector;
 use Illuminate\Queue\Connectors\RedisConnector;
@@ -104,7 +105,7 @@ protected function registerConnection()
      */
     public function registerConnectors($manager)
     {
-        foreach (['Null', 'Sync', 'Failover', 'Database', 'Redis', 'Beanstalkd', 'Sqs'] as $connector) {
+        foreach (['Null', 'Sync', 'Deferred', 'Failover', 'Database', 'Redis', 'Beanstalkd', 'Sqs'] as $connector) {
             $this->{"register{$connector}Connector"}($manager);
         }
     }
@@ -135,6 +136,19 @@ protected function registerSyncConnector($manager)
         });
     }
 
+    /**
+     * Register the Deferred queue connector.
+     *
+     * @param  \Illuminate\Queue\QueueManager  $manager
+     * @return void
+     */
+    protected function registerDeferredConnector($manager)
+    {
+        $manager->addConnector('deferred', function () {
+            return new DeferredConnector;
+        });
+    }
+
     /**
      * Register the Failover queue connector.
      *