Abstract Class yii\queue\Queue
| Inheritance | yii\queue\Queue » yii\base\Component | 
|---|---|
| Subclasses | yii\queue\amqp\Queue, yii\queue\amqp_interop\Queue, yii\queue\beanstalk\Queue, yii\queue\cli\Queue, yii\queue\db\Queue, yii\queue\file\Queue, yii\queue\gearman\Queue, yii\queue\redis\Queue, yii\queue\sync\Queue | 
| Available since version | 2.0.2 | 
Base Queue
Public Properties
| Property | Type | Description | Defined By | 
|---|---|---|---|
| $attempts | integer | Default attempt count | yii\queue\Queue | 
| $serializer | yii\queue\serializers\SerializerInterface|array | yii\queue\Queue | |
| $strictJobType | boolean | Whether to enable strict job type control. | yii\queue\Queue | 
| $ttr | integer | Default time to reserve a job | yii\queue\Queue | 
Public Methods
| Method | Description | Defined By | 
|---|---|---|
| delay() | Sets delay for later execute | yii\queue\Queue | 
| getWorkerPid() | Uses for CLI drivers and gets process ID of a worker. | yii\queue\Queue | 
| handleError() | yii\queue\Queue | |
| init() | yii\queue\Queue | |
| isDone() | yii\queue\Queue | |
| isReserved() | yii\queue\Queue | |
| isWaiting() | yii\queue\Queue | |
| priority() | Sets job priority | yii\queue\Queue | 
| push() | Pushes job into queue | yii\queue\Queue | 
| status() | yii\queue\Queue | |
| ttr() | Sets TTR for job execute | yii\queue\Queue | 
Protected Methods
| Method | Description | Defined By | 
|---|---|---|
| handleMessage() | yii\queue\Queue | |
| pushMessage() | yii\queue\Queue | 
Events
Constants
| Constant | Value | Description | Defined By | 
|---|---|---|---|
| STATUS_DONE | 3 | yii\queue\Queue | |
| STATUS_RESERVED | 2 | yii\queue\Queue | |
| STATUS_WAITING | 1 | yii\queue\Queue | 
Property Details
Default attempt count
public yii\queue\serializers\SerializerInterface|array $serializer = \yii\queue\serializers\PhpSerializer::class
    
    
    Whether to enable strict job type control. Note that in order to enable type control, a pushing job must be yii\queue\JobInterface instance.
Default time to reserve a job
Method Details
Sets delay for later execute
| public $this delay ( $value ) | ||
| $value | integer|mixed | |
Uses for CLI drivers and gets process ID of a worker.
| public null getWorkerPid ( ) | 
| public boolean handleError ( $id, $job, $ttr, $attempt, $error ) | ||
| $id | string|null | |
| $job | yii\queue\JobInterface | |
| $ttr | integer | |
| $attempt | integer | |
| $error | Exception|Throwable | |
| protected boolean handleMessage ( $id, $message, $ttr, $attempt ) | ||
| $id | string | Of a job message | 
| $message | string | |
| $ttr | integer | Time to reserve | 
| $attempt | integer | Number | 
| public void init ( ) | 
| public boolean isDone ( $id ) | ||
| $id | string | Of a job message | 
| public boolean isReserved ( $id ) | ||
| $id | string | Of a job message | 
| public boolean isWaiting ( $id ) | ||
| $id | string | Of a job message | 
Sets job priority
| public $this priority ( $value ) | ||
| $value | mixed | |
Pushes job into queue
| public string|null push ( $job ) | ||
| $job | yii\queue\JobInterface|mixed | |
| return | string|null | Id of a job message | 
|---|---|---|
| protected abstract string pushMessage ( $message, $ttr, $delay, $priority ) | ||
| $message | string | |
| $ttr | integer | Time to reserve in seconds | 
| $delay | integer | |
| $priority | mixed | |
| return | string | Id of a job message | 
|---|---|---|
| public abstract integer status ( $id ) | ||
| $id | string | Of a job message | 
| return | integer | Status code | 
|---|---|---|
Sets TTR for job execute
| public $this ttr ( $value ) | ||
| $value | integer|mixed | |