Class yii\queue\amqp_interop\Queue
| Inheritance | yii\queue\amqp_interop\Queue » yii\queue\cli\Queue » yii\queue\Queue » yii\base\Component » yii\base\BaseObject |
|---|---|
| Implements | yii\base\BootstrapInterface, yii\base\Configurable |
| Available since version | 2.0.2 |
| Source Code | https://github.com/yiisoft/yii2-queue/blob/master/amqp_interop/Queue.php |
Amqp Queue.
Public Properties
Protected Properties
| Property | Type | Description | Defined By |
|---|---|---|---|
| $context | \Interop\Amqp\AmqpContext | yii\queue\amqp_interop\Queue | |
| $setupBrokerDone | boolean | yii\queue\amqp_interop\Queue | |
| $supportedDrivers | string[] | yii\queue\amqp_interop\Queue |
Public Methods
| Method | Description | Defined By |
|---|---|---|
| __call() | Calls the named method which is not a class method. | yii\base\Component |
| __clone() | This method is called after the object is created by cloning an existing one. | yii\base\Component |
| __construct() | Constructor. | yii\base\BaseObject |
| __get() | Returns the value of a component property. | yii\base\Component |
| __isset() | Checks if a property is set, i.e. defined and not null. | yii\base\Component |
| __set() | Sets the value of a component property. | yii\base\Component |
| __unset() | Sets a component property to be null. | yii\base\Component |
| attachBehavior() | Attaches a behavior to this component. | yii\base\Component |
| attachBehaviors() | Attaches a list of behaviors to the component. | yii\base\Component |
| behaviors() | Returns a list of behaviors that this component should behave as. | yii\base\Component |
| bootstrap() | Bootstrap method to be called during application bootstrap stage. | yii\queue\cli\Queue |
| canGetProperty() | Returns a value indicating whether a property can be read. | yii\base\Component |
| canSetProperty() | Returns a value indicating whether a property can be set. | yii\base\Component |
| className() | Returns the fully qualified name of this class. | yii\base\BaseObject |
| delay() | Sets delay for later execute. | yii\queue\Queue |
| detachBehavior() | Detaches a behavior from the component. | yii\base\Component |
| detachBehaviors() | Detaches all behaviors from the component. | yii\base\Component |
| ensureBehaviors() | Makes sure that the behaviors declared in behaviors() are attached to this component. | yii\base\Component |
| execute() | yii\queue\cli\Queue | |
| getBehavior() | Returns the named behavior object. | yii\base\Component |
| getBehaviors() | Returns all behaviors attached to this component. | yii\base\Component |
| getContext() | yii\queue\amqp_interop\Queue | |
| getWorkerPid() | Gets process ID of a worker. | yii\queue\cli\Queue |
| handleError() | yii\queue\Queue | |
| hasEventHandlers() | Returns a value indicating whether there is any handler attached to the named event. | yii\base\Component |
| hasMethod() | Returns a value indicating whether a method is defined. | yii\base\Component |
| hasProperty() | Returns a value indicating whether a property is defined for this component. | yii\base\Component |
| init() | Initializes the object. | yii\queue\amqp_interop\Queue |
| isDone() | yii\queue\Queue | |
| isReserved() | yii\queue\Queue | |
| isWaiting() | yii\queue\Queue | |
| listen() | Listens amqp-queue and runs new jobs. | yii\queue\amqp_interop\Queue |
| off() | Detaches an existing event handler from this component. | yii\base\Component |
| on() | Attaches an event handler to an event. | yii\base\Component |
| priority() | Sets job priority. | yii\queue\Queue |
| push() | Pushes job into queue. | yii\queue\Queue |
| status() | yii\queue\amqp_interop\Queue | |
| trigger() | Triggers an event. | yii\base\Component |
| ttr() | Sets TTR for job execute. | yii\queue\Queue |
| unserializeMessage() | Unserializes. | yii\queue\Queue |
Protected Methods
| Method | Description | Defined By |
|---|---|---|
| close() | Closes connection and channel. | yii\queue\amqp_interop\Queue |
| getCommandId() | yii\queue\cli\Queue | |
| handleMessage() | yii\queue\cli\Queue | |
| open() | Opens connection and channel. | yii\queue\amqp_interop\Queue |
| pushMessage() | yii\queue\amqp_interop\Queue | |
| redeliver() | yii\queue\amqp_interop\Queue | |
| runWorker() | Runs worker. | yii\queue\cli\Queue |
| setupBroker() | yii\queue\amqp_interop\Queue |
Events
| Event | Type | Description | Defined By |
|---|---|---|---|
| EVENT_AFTER_ERROR | yii\queue\ExecEvent | yii\queue\Queue | |
| EVENT_AFTER_EXEC | yii\queue\ExecEvent | yii\queue\Queue | |
| EVENT_AFTER_PUSH | yii\queue\PushEvent | yii\queue\Queue | |
| EVENT_BEFORE_EXEC | yii\queue\ExecEvent | yii\queue\Queue | |
| EVENT_BEFORE_PUSH | yii\queue\PushEvent | yii\queue\Queue | |
| EVENT_WORKER_LOOP | yii\queue\cli\WorkerEvent | That is triggered each iteration between requests to queue. (available since version 2.0.3) | yii\queue\cli\Queue |
| EVENT_WORKER_START | yii\queue\cli\WorkerEvent | That is triggered when the worker is started. (available since version 2.0.2) | yii\queue\cli\Queue |
| EVENT_WORKER_STOP | yii\queue\cli\WorkerEvent | That is triggered when the worker is stopped. (available since version 2.0.2) | yii\queue\cli\Queue |
Constants
| Constant | Value | Description | Defined By |
|---|---|---|---|
| ATTEMPT | 'yii-attempt' | yii\queue\amqp_interop\Queue | |
| DELAY | 'yii-delay' | yii\queue\amqp_interop\Queue | |
| ENQUEUE_AMQP_BUNNY | 'enqueue/amqp-bunny' | yii\queue\amqp_interop\Queue | |
| ENQUEUE_AMQP_EXT | 'enqueue/amqp-ext' | yii\queue\amqp_interop\Queue | |
| ENQUEUE_AMQP_LIB | 'enqueue/amqp-lib' | yii\queue\amqp_interop\Queue | |
| PRIORITY | 'yii-priority' | yii\queue\amqp_interop\Queue | |
| STATUS_DONE | 3 | yii\queue\Queue | |
| STATUS_RESERVED | 2 | yii\queue\Queue | |
| STATUS_WAITING | 1 | yii\queue\Queue | |
| TTR | 'yii-ttr' | yii\queue\amqp_interop\Queue |
Property Details
Command class name
protected string[] $supportedDrivers = [
self::ENQUEUE_AMQP_LIB,
self::ENQUEUE_AMQP_EXT,
self::ENQUEUE_AMQP_BUNNY
]
self::ENQUEUE_AMQP_LIB,
self::ENQUEUE_AMQP_EXT,
self::ENQUEUE_AMQP_BUNNY
]
Method Details
Closes connection and channel.
| protected void close ( ) |
| public \Interop\Amqp\AmqpContext getContext ( ) |
Initializes the object.
This method is invoked at the end of the constructor after the object is initialized with the given configuration.
| public void init ( ) |
Listens amqp-queue and runs new jobs.
| public void listen ( ) |
Opens connection and channel.
| protected void open ( ) |
| protected string pushMessage ( $payload, $ttr, $delay, $priority ) | ||
| $payload | ||
| $ttr | integer | Time to reserve in seconds |
| $delay | integer | |
| $priority | mixed | |
| return | string | Id of a job message |
|---|---|---|
| protected void redeliver ( \Interop\Amqp\AmqpMessage $message ) | ||
| $message | ||
| protected void setupBroker ( ) |
| public integer status ( $id ) | ||
| $id | string | Of a job message |
| return | integer | Status code |
|---|---|---|