AdapterInterface
in
Adapter interface
Tags
Table of Contents
Methods
- bury() : AdapterInterface
- Move a job to the dead-letter store (terminal)
- clear() : AdapterInterface
- Clear pending and reserved jobs (not dead-letter jobs)
- clearDead() : AdapterInterface
- count() : int
- Count of pending + reserved jobs
- countDead() : int
- delete() : AdapterInterface
- Permanently remove a job (success/ack)
- deleteDeadJob() : AdapterInterface
- getDeadJob() : mixed
- getDeadJobs() : array<string|int, mixed>
- getPriority() : string
- hasDeadJobs() : bool
- hasJobs() : bool
- Whether there are pending or reserved jobs
- isFifo() : bool
- isFilo() : bool
- isLifo() : bool
- isLilo() : bool
- push() : AdapterInterface
- Push a job onto the queue
- release() : AdapterInterface
- Put a reserved job back to pending. $delay overrides the job's own backoff schedule when given; otherwise release() computes the delay from $job->getBackoffDelay().
- reserve() : AbstractJob|null
- Atomically claim the next eligible job and lease it. Returns null if nothing is eligible (no pending jobs due, or all reserved jobs have a live lease).
- retryDeadJob() : AdapterInterface
- Move a dead-letter job back to pending
- setPriority() : AdapterInterface
Methods
bury()
Move a job to the dead-letter store (terminal)
public
bury(AbstractJob $job[, string|null $reason = null ]) : AdapterInterface
Parameters
- $job : AbstractJob
- $reason : string|null = null
Return values
AdapterInterfaceclear()
Clear pending and reserved jobs (not dead-letter jobs)
public
clear() : AdapterInterface
Return values
AdapterInterfaceclearDead()
public
clearDead() : AdapterInterface
Return values
AdapterInterfacecount()
Count of pending + reserved jobs
public
count() : int
Return values
intcountDead()
public
countDead() : int
Return values
intdelete()
Permanently remove a job (success/ack)
public
delete(AbstractJob $job) : AdapterInterface
Parameters
- $job : AbstractJob
Return values
AdapterInterfacedeleteDeadJob()
public
deleteDeadJob(string $jobId) : AdapterInterface
Parameters
- $jobId : string
Return values
AdapterInterfacegetDeadJob()
public
getDeadJob(string $jobId[, bool $unserialize = true ]) : mixed
Parameters
- $jobId : string
- $unserialize : bool = true
getDeadJobs()
public
getDeadJobs([bool $unserialize = true ]) : array<string|int, mixed>
Parameters
- $unserialize : bool = true
Return values
array<string|int, mixed>getPriority()
public
getPriority() : string
Return values
stringhasDeadJobs()
public
hasDeadJobs() : bool
Return values
boolhasJobs()
Whether there are pending or reserved jobs
public
hasJobs() : bool
Return values
boolisFifo()
public
isFifo() : bool
Return values
boolisFilo()
public
isFilo() : bool
Return values
boolisLifo()
public
isLifo() : bool
Return values
boolisLilo()
public
isLilo() : bool
Return values
boolpush()
Push a job onto the queue
public
push(AbstractJob $job) : AdapterInterface
Parameters
- $job : AbstractJob
Return values
AdapterInterfacerelease()
Put a reserved job back to pending. $delay overrides the job's own backoff schedule when given; otherwise release() computes the delay from $job->getBackoffDelay().
public
release(AbstractJob $job[, int|null $delay = null ]) : AdapterInterface
Parameters
- $job : AbstractJob
- $delay : int|null = null
Return values
AdapterInterfacereserve()
Atomically claim the next eligible job and lease it. Returns null if nothing is eligible (no pending jobs due, or all reserved jobs have a live lease).
public
reserve() : AbstractJob|null
Return values
AbstractJob|nullretryDeadJob()
Move a dead-letter job back to pending
public
retryDeadJob(string $jobId) : AdapterInterface
Parameters
- $jobId : string
Return values
AdapterInterfacesetPriority()
public
setPriority([string $priority = 'FIFO' ]) : AdapterInterface
Parameters
- $priority : string = 'FIFO'