BeanstalkdQueue
class BeanstalkdQueue extends Queue implements QueueInterface (View source)
Properties
| protected Container | $container | The IoC container instance. |
from Queue |
| protected Pheanstalk_Pheanstalk | $pheanstalk | The Pheanstalk instance. |
|
| protected string | $default | The name of the default tube. |
|
| protected int | $timeToRun | The "time to run" for all pushed jobs. |
Methods
Push an array of jobs onto the queue.
Create a payload string from the given job and data.
Set additional meta on a payload string.
Create a new Beanstalkd queue instance.
Push a new job onto the queue.
Push a raw payload onto the queue.
Delete a message from the Beanstalk queue.
Get the queue or return the default.
Get the underlying Pheanstalk instance.
Details
in
Queue at line 23
marshal()
Marshal a push queue request and fire the job.
in
Queue at line 36
mixed
bulk(array $jobs, mixed $data = '', string $queue = null)
Push an array of jobs onto the queue.
in
Queue at line 52
protected string
createPayload(string $job, mixed $data = '', string $queue = null)
Create a payload string from the given job and data.
in
Queue at line 69
protected string
createClosurePayload(Closure $job, mixed $data)
Create a payload string for the given Closure job.
in
Queue at line 84
protected string
setMeta(string $payload, string $key, string $value)
Set additional meta on a payload string.
in
Queue at line 97
protected int
getSeconds(DateTime|int $delay)
Calculate the number of seconds with the given delay.
in
Queue at line 112
int
getTime()
Get the current UNIX timestamp.
in
Queue at line 123
void
setContainer(Container $container)
Set the IoC container instance.
in
Queue at line 134
void
setEncrypter(Encrypter $crypt)
Set the encrypter instance.
void
__construct(Pheanstalk_Pheanstalk $pheanstalk, string $default, int $timeToRun)
Create a new Beanstalkd queue instance.
mixed
push(string $job, mixed $data = '', string $queue = null)
Push a new job onto the queue.
mixed
pushRaw(string $payload, string $queue = null, array $options = array())
Push a raw payload onto the queue.
mixed
later(DateTime|int $delay, string $job, mixed $data = '', string $queue = null)
Push a new job onto the queue after a delay.
Job|null
pop(string $queue = null)
Pop the next job off of the queue.
void
deleteMessage(string $queue, string $id)
Delete a message from the Beanstalk queue.
string
getQueue(string|null $queue)
Get the queue or return the default.
Pheanstalk_Pheanstalk
getPheanstalk()
Get the underlying Pheanstalk instance.