Gitee
\
Freyo
LaravelQueueCMQ
Queue
Connectors
Driver
Jobs

\Freyo\LaravelQueueCMQ\QueueCMQQueue

Summary

Methods
Properties
Constants
__construct()
size()
push()
pushRaw()
later()
pop()
getQueue()
getTopic()
parseQueue()
No public properties found
CMQ_QUEUE_NO_MESSAGE_CODE
CMQ_TOPIC_TAG_FILTER_NAME
CMQ_TOPIC_ROUTING_FILTER_NAME
No protected methods found
$queueOptions
$topicOptions
N/A
No private methods found
$queueAccount
$topicAccount
N/A

Constants

CMQ_QUEUE_NO_MESSAGE_CODE

CMQ_QUEUE_NO_MESSAGE_CODE = 7000

CMQ_TOPIC_TAG_FILTER_NAME

CMQ_TOPIC_TAG_FILTER_NAME = 'msgtag'

CMQ_TOPIC_ROUTING_FILTER_NAME

CMQ_TOPIC_ROUTING_FILTER_NAME = 'routing'

Properties

$queueOptions

$queueOptions : array

Type

array

$topicOptions

$topicOptions :

Type

$topicAccount

$topicAccount :

Type

Methods

size()

size(string  $queue = null) : integer

Get the size of the queue.

Parameters

string $queue

Returns

integer

push()

push(string|object  $job, mixed  $data = '', string  $queue = null) : mixed

Push a new job onto the queue.

Parameters

string|object $job
mixed $data
string $queue

Returns

mixed

pushRaw()

pushRaw(string  $payload, string  $queue = null, array  $options = array()) : mixed

Push a raw payload onto the queue.

Parameters

string $payload
string $queue
array $options

Returns

mixed

later()

later(\DateTimeInterface|\DateInterval|integer  $delay, string|object  $job, mixed  $data = '', string  $queue = null) : mixed

Push a new job onto the queue after a delay.

Parameters

\DateTimeInterface|\DateInterval|integer $delay
string|object $job
mixed $data
string $queue

Returns

mixed

pop()

pop(string  $queue = null) : \Illuminate\Contracts\Queue\Job|null

Pop the next job off of the queue.

Parameters

string $queue

Returns

\Illuminate\Contracts\Queue\Job|null