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 |