archtechx/jobpipeline
1
0
Fork 0
mirror of https://github.com/archtechx/jobpipeline.git synced 2025-12-12 23:34:04 +00:00
Code Activity

The following methods where added: onConnection, onQueue, delay, tries, shouldBeQueuedOn. The signature of shouldBeQueued was changed too.

Browse source
This commit is contained in:
Jonathan Martins 2023-02-25 11:49:51 -03:00
parent 1ba255a4f4
commit 7e618f6950
1 changed files with 51 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

58
src/JobPipeline.php
View file

@ -25,10 +25,16 @@ class JobPipeline implements ShouldQueue
public $passable;
/** @var bool */
public $shouldBeQueued;
public bool $shouldBeQueued;
/** @var string */
public $queue;
public string|null $queue;
/** @var string */
public string|null $connection;
/** @var int */
public int $tries = 1;
public function __construct($jobs, callable $send = null, bool $shouldBeQueued = null)
{
@ -53,20 +59,58 @@ class JobPipeline implements ShouldQueue
return $this;
}
public function shouldBeQueued(bool $shouldBeQueued = true)
public function shouldBeQueued(bool|string $shouldBeQueued = true)
{
$this->shouldBeQueued = $shouldBeQueued;
if (is_string($shouldBeQueued))
{
$this->onQueue($shouldBeQueued);
$this->shouldBeQueued = true;
}
else
{
$this->shouldBeQueued = $shouldBeQueued;
}
return $this;
}
public function onQueue(string $queue)
public function shouldBeQueuedOn(string $queue)
{
$this->shouldBeQueued = true;
$this->onQueue($queue);
return $this;
}
public function onConnection(null|string $connection)
{
$this->connection = $connection;
return $this;
}
public function onQueue(null|string $queue)
{
$this->queue = $queue;
return $this;
}
public function delay($delay)
{
$this->delay = $delay;
return $this;
}
public function tries($tries)
{
$this->tries = $tries;
return $this;
}
public function handle(): void
{
foreach ($this->jobs as $job) {