OutboxWorker
class OutboxWorker
Methods
Create a worker with invocation-local admission and shutdown state.
Relay committed work until the requested limit or shutdown condition is reached.
Report a failed claim after its database-owning coroutine has ended.
Read the restart signal without retaining a cache connection on the coordinator.
Join every owned task before propagating cancellation, including repeated cancellation during cleanup.
Details
at line 26
__construct(DatabaseOutboxRepository $repository, OutboxRelay $relay, Factory $cache, ExceptionHandler $exceptions, SignalRegistry $signals)
Create a worker with invocation-local admission and shutdown state.
at line 38
int
run(string|null $database, OutboxWorkerOptions $options)
Relay committed work until the requested limit or shutdown condition is reached.
at line 172
protected array|null
claim(string $database, int $limit)
Report a failed claim after its database-owning coroutine has ended.
at line 195
protected int|null
restartTimestamp()
Read the restart signal without retaining a cache connection on the coordinator.
at line 212
protected void
join(WaitConcurrent $concurrent)
Join every owned task before propagating cancellation, including repeated cancellation during cleanup.