QueueAdapter
abstract class QueueAdapter (View source)
Constants
| EXIT_SUCCESS |
|
| EXIT_ERROR |
|
| EXIT_MEMORY_LIMIT |
|
Properties
| protected float | $start_time | Define the start time |
|
| protected float | $processing_timeout | Define the processing timeout |
|
| protected int | $timeout | Define the work time out |
|
| protected string | $queue | Determine the default watch name |
|
| protected int | $tries | The number of working attempts |
|
| protected int | $sleep | Define the sleep time |
|
| static protected bool | $suppressLogging | Whether to suppress logging (useful for testing) |
Methods
Enable or disable logging suppression
Make adapter configuration
Create task unserialize
Sleep the process
Set worker timeout
Update the processing timeout
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 task tries
Get task tries
Set sleep time
Get the queue or return the default.
Watch the queue name
Get the queue size
Flush the queue
Generate the task id
Details
static void
suppressLogging(bool $suppress = true)
Enable or disable logging suppression
abstract QueueAdapter
configure(array $config)
Make adapter configuration
abstract bool
push(QueueTask $task)
Push new task
string
serializeProducer(QueueTask $task)
Create task serialization
QueueTask
unserializeProducer(string $task)
Create task unserialize
void
sleep(int $seconds)
Sleep the process
void
setTimeout(int $timeout)
Set worker timeout
void
updateProcessingTimeout(int|null $timeout = null)
Update the processing timeout
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 task tries
int
getTries()
Get task 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
int
size(string|null $queue = null)
Get the queue size
void
flush(string|null $queue = null)
Flush the queue
protected void
logError(Throwable $exception)
Log an error
final protected string
generateId()
Generate the task id
protected void
logProcessingTask(QueueTask $task)
Log processing task
protected void
logProcessedTask(QueueTask $task)
Log processed task