IronQueue
class IronQueue extends Queue implements QueueInterface (View source)
Properties
| protected Container | $container | The IoC container instance. |
from Queue |
| protected IronMQ | $iron | The IronMQ instance. |
|
| protected Request | $request | The current request instance. |
|
| protected string | $default | The name of the default tube. |
|
| protected bool | $shouldEncrypt | Indicates if the messages should be encrypted. |
Methods
Marshal a push queue request and fire the job.
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 IronMQ queue instance.
Push a new job onto the queue.
Push a raw payload onto the queue.
Push a raw payload onto the queue after encrypting the payload.
Delete a message from the Iron queue.
Marshal out the pushed job and payload.
Create a new IronJob for a pushed job.
Parse the job body for firing.
Get the queue or return the default.
Get the underlying IronMQ instance.
Get the request instance.
Details
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.
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(IronMQ $iron, Request $request, string $default, bool $shouldEncrypt = false)
Create a new IronMQ 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
recreate(string $payload, string $queue = null, int $delay)
Push a raw payload onto the queue after encrypting the payload.
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 Iron queue.
protected object
marshalPushedJob()
Marshal out the pushed job and payload.
protected IronJob
createPushedIronJob(object $job)
Create a new IronJob for a pushed job.
protected string
parseJobBody(string $body)
Parse the job body for firing.
string
getQueue(string|null $queue)
Get the queue or return the default.
IronMQ
getIron()
Get the underlying IronMQ instance.
Request
getRequest()
Get the request instance.
void
setRequest(Request $request)
Set the request instance.