diff --git a/src/JobPipeline.php b/src/JobPipeline.php index a3f7bc3..8e69dce 100644 --- a/src/JobPipeline.php +++ b/src/JobPipeline.php @@ -26,6 +26,9 @@ class JobPipeline implements ShouldQueue /** @var bool */ public $shouldBeQueued; + + /** @var string */ + public $queue; public function __construct($jobs, callable $send = null, bool $shouldBeQueued = null) { @@ -56,6 +59,13 @@ class JobPipeline implements ShouldQueue return $this; } + + public function onQueue(string $queue) + { + $this->queue = $queue; + + return $this; + } public function handle(): void {