BeanstalkdAdapter
class BeanstalkdAdapter extends QueueAdapter (View source)
Constants
| EXIT_SUCCESS |
|
| EXIT_ERROR |
|
| EXIT_MEMORY_LIMIT |
|
Properties
| protected float | $start_time | Define the start time |
from QueueAdapter |
| protected string | $queue | Determine the default watch name |
from QueueAdapter |
| protected int | $tries | The number of working attempts |
from QueueAdapter |
| protected int | $sleep | Define the sleep time |
from QueueAdapter |
Methods
configure(array $config)
Configure Beanstalkd driver
void
run(string|null $queue = null)
Run the worker
int
size(string $queue = null)
Get the size of the queue.
void
flush(string|null $queue = null)
Flush the queue
int
getPriority(int $priority)
Get the priority
Details
QueueAdapter
configure(array $config)
Configure Beanstalkd driver
void
push(QueueJob $producer)
Queue a job
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)
Run the worker
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 = null)
Get the size of the queue.
void
flush(string|null $queue = null)
Flush the queue
int
getPriority(int $priority)
Get the priority