ApprovalSyncJobService
in package
uses
LocatorAwareTrait
Bounded, resumable tenant-queue coordination; each restart and its result commit together.
Table of Contents
Properties
Methods
- __construct() : mixed
- Initialize collaborators.
- enqueue() : EntityInterface
- Enqueue or return the active process synchronization.
- latest() : array<string|int, mixed>
- Read durable progress without changing the run.
- work() : void
- Each queue delivery processes one page or one recommendation, never the whole run.
- fingerprint() : string
- Capture the process and published workflow configuration.
- hasExhaustedJob() : bool
- Detect deliveries that exhausted the worker retry budget.
- queue() : void
- Enqueue tenant-local work in the current transaction.
- stop() : void
- Stop pending work with a safe explanation.
Properties
$sync
private
RecommendationApprovalWorkflowSyncService
$sync
Methods
__construct()
Initialize collaborators.
public
__construct(RecommendationApprovalWorkflowSyncService $sync) : mixed
Parameters
enqueue()
Enqueue or return the active process synchronization.
public
enqueue(int $processId, int $actorId) : EntityInterface
Parameters
- $processId : int
- $actorId : int
Return values
EntityInterfacelatest()
Read durable progress without changing the run.
public
latest(int $processId[, int $page = 1 ]) : array<string|int, mixed>
Parameters
- $processId : int
- $page : int = 1
Return values
array<string|int, mixed>work()
Each queue delivery processes one page or one recommendation, never the whole run.
public
work(array<string|int, mixed> $data) : void
Parameters
- $data : array<string|int, mixed>
fingerprint()
Capture the process and published workflow configuration.
private
fingerprint(int $processId) : string
Parameters
- $processId : int
Return values
stringhasExhaustedJob()
Detect deliveries that exhausted the worker retry budget.
private
hasExhaustedJob(int $runId) : bool
Parameters
- $runId : int
Return values
boolqueue()
Enqueue tenant-local work in the current transaction.
private
queue(array<string|int, mixed> $data) : void
Parameters
- $data : array<string|int, mixed>
stop()
Stop pending work with a safe explanation.
private
stop(EntityInterface $run, string $message) : void
Parameters
- $run : EntityInterface
- $message : string