QueueAdapter
abstract class QueueAdapter (View source)
Constants
| EXIT_SUCCESS |
|
| EXIT_ERROR |
|
| EXIT_MEMORY_LIMIT |
|
Properties
| protected float | $start_time | Define the start time |
|
| protected string | $queue | Determine the default watch name |
|
| protected int | $tries | The number of working attempts |
|
| protected int | $sleep | Define the sleep time |
Methods
Make adapter configuration
Create producer unserialize
Sleep the process
Launch the worker
Determine if "async" signals are supported.
Enable async signals for the process.
Start the worker server
Determine if the timeout is reached
Kill the process.
Set job tries
Set sleep time
Get the queue or return the default.
Watch the queue name
Generate the job id
Get the queue size
Flush the queue
Details
abstract QueueAdapter
configure(array $config)
Make adapter configuration
abstract void
push(QueueJob $producer)
Push new producer
string
serializeProducer(QueueJob $producer)
Create producer serialization
QueueJob
unserializeProducer(string $producer)
Create producer unserialize
void
sleep(int $seconds)
Sleep the process
final void
work(int $timeout, int $memory)
Launch the worker
protected bool
supportsAsyncSignals()
Determine if "async" signals are supported.
protected void
listenForSignals()
Enable async signals for the process.
void
run(string|null $queue = null)
Start the worker server
protected bool
timeoutReached(int $timeout)
Determine if the timeout is reached
void
kill(int $status = 0)
Kill the process.
void
setTries(int $tries)
Set job tries
void
setSleep(int $sleep)
Set sleep time
string
getQueue(string|null $queue = null)
Get the queue or return the default.
void
setQueue(string $queue)
Watch the queue name
string
generateId()
Generate the job id
int
size(string $queue)
Get the queue size
void
flush(string|null $queue = null)
Flush the queue