archtechx/jobpipeline
1
0
Fork 0
mirror of https://github.com/archtechx/jobpipeline.git synced 2025-12-13 16:54:03 +00:00
Code Activity

added timeout

Browse source
This commit is contained in:
Jonathan Martins 2023-02-25 12:16:12 -03:00
parent a9c716d1a1
commit 63f58e6a99
1 changed files with 15 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

18
src/JobPipeline.php
View file

@ -28,10 +28,15 @@ class JobPipeline implements ShouldQueue
public bool $shouldBeQueued; public bool $shouldBeQueued;
/** @var string */ /** @var string */
public string|null $queue; public string|null $connection;
/** @var string */ /** @var string */
public string|null $connection; public string|null $queue;
/** @var int */
public int $timeout = 1;
public $delay = 0;
/** @var int */ /** @var int */
public int $tries = 1; public int $tries = 1;
@ -96,6 +101,13 @@ class JobPipeline implements ShouldQueue
return $this; return $this;
} }
public function timeout(int $timeoutInSeconds)
{
$this->timeout = $timeoutInSeconds;
return $this;
}
public function delay($delay) public function delay($delay)
{ {
$this->delay = $delay; $this->delay = $delay;
@ -103,7 +115,7 @@ class JobPipeline implements ShouldQueue
return $this; return $this;
} }
public function tries($tries) public function tries(int $tries)
{ {
$this->tries = $tries; $this->tries = $tries;