QueueAdapter
abstract class QueueAdapter (View source)
Constants
| EXIT_SUCCESS |
|
| EXIT_ERROR |
|
| EXIT_MEMORY_LIMIT |
|
Properties
| protected int | $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
Laund the worker
Kill the process.
Determine if the timeout is reached
Enable async signals for the process.
Determine if "async" signals are supported.
Set job tries
Set sleep time
Get the queue or return the default.
Generate the job id
Get the queue size
Start the worker server
Flush the queue
Watch the queue name
Details
abstract QueueAdapter
configure(array $config)
Make adapter configuration
abstract void
push(ProducerService $producer)
Push new producer
string
serializeProducer(ProducerService $producer)
Create producer serialization
ProducerService
unserializeProducer(string $producer)
Create producer unserialize
void
sleep(int $seconds)
Sleep the process
final void
work(int $timeout, int $memory)
Laund the worker
never
kill(int $status = 0)
Kill the process.
protected bool
timeoutReached(int $timeout)
Determine if the timeout is reached
protected void
listenForSignals()
Enable async signals for the process.
protected bool
supportsAsyncSignals()
Determine if "async" signals are supported.
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.
string
generateId()
Generate the job id
int
size(string $queue)
Get the queue size
void
run(string|null $queue = null)
Start the worker server
void
flush(string|null $queue = null)
Flush the queue
void
setQueue(string $queue)
Watch the queue name