[12.x] Pause a queue for given seconds

src/Illuminate/Queue/QueueManager.php

@@ -211,6 +211,21 @@ public function pause($connection, $queue)
             ->forever("illuminate:queue:paused:{$connection}:{$queue}", true);
     }
 
+    /**
+     * Pause a queue by its connection and name for a given number of seconds.
+     *
+     * @param  string  $connection
+     * @param  string  $queue
+     * @param  int  $seconds
+     * @return void
+     */
+    public function pauseFor($connection, $queue, $seconds)
+    {
+        $this->app['cache']
+            ->store()
+            ->put("illuminate:queue:paused:{$connection}:{$queue}", true, $seconds);
+    }
+
     /**
      * Resume a paused queue by its connection and name.
      *

src/Illuminate/Support/Facades/Queue.php

@@ -16,6 +16,7 @@
  * @method static bool connected(string|null $name = null)
  * @method static \Illuminate\Contracts\Queue\Queue connection(string|null $name = null)
  * @method static void pause(string $connection, string $queue)
+ * @method static void pauseFor(string $connection, string $queue, int $seconds)
  * @method static void resume(string $connection, string $queue)
  * @method static bool isPaused(string $connection, string $queue)
  * @method static void extend(string $driver, \Closure $resolver)

tests/Queue/QueuePauseResumeTest.php

@@ -6,6 +6,7 @@
 use Illuminate\Cache\Repository;
 use Illuminate\Queue\Console\Concerns\ParsesQueue;
 use Illuminate\Queue\QueueManager;
+use Illuminate\Support\Carbon;
 use Mockery as m;
 use PHPUnit\Framework\TestCase;
 
@@ -51,15 +52,23 @@ public function testPauseQueueWithConnection()
 
     public function testPauseQueueWithTTL()
     {
-        $this->manager->pause('redis', 'default', 60);
+        Carbon::setTestNow();
+        $this->manager->pauseFor('redis', 'default', 30);
 
         $this->assertTrue($this->manager->isPaused('redis', 'default'));
+
+        Carbon::setTestNow(Carbon::now()->addMinute());
+        $this->assertFalse($this->manager->isPaused('redis', 'default'));
     }
 
     public function testPauseQueueIndefinitely()
     {
-        $this->manager->pause('redis', 'default', null);
+        Carbon::setTestNow();
+        $this->manager->pause('redis', 'default');
+
+        $this->assertTrue($this->manager->isPaused('redis', 'default'));
 
+        Carbon::setTestNow(Carbon::now()->addYear());
         $this->assertTrue($this->manager->isPaused('redis', 'default'));
     }