README

This component provides simple queue wrapper

I recommend yii2-asynctask.

Requirements

Redis yii2-redis

Installation

The preferred way to install this extension is through composer.

Either run

php composer.phar require --prefer-dist wayhood/yii2-queue "*" 

or add

"wayhood/yii2-queue": "*" 

to the require section of your composer.json file.

Usage

To use this extension, simply add the following code in your application configuration:

return [ //.... 'components' => [ 'queue' => [ 'class' => 'wh\queue\RedisQueue', ], 'redis' => [ 'class' => 'yii\redis\Connection', 'hostname' => 'localhost', 'port' => 6379, 'database' => 0 ], ], ];

First create a Job process class

namespace console\jobs; class MyJob { public function run($job, $data) { //process $data; var_dump($data); } } 

and than just push job to queue

// Push job to the default queue and execute "run" method Yii::$app->queue->push('\console\jobs\MyJob', ['a', 'b', 'c']); // or push it and execute any other method Yii::$app->queue->push('\console\jobs\MyJob@myMethod', ['a', 'b', 'c']); // or push it to some specific queue Yii::$app->queue->push('\console\jobs\MyJob', ['a', 'b', 'c'], 'myQueue'); // or both Yii::$app->queue->push('\console\jobs\MyJob@myMethod', ['a', 'b', 'c'], 'myQueue');

Map console controller in your app config

return [ ... 'controllerMap' => [ 'queue' => 'wh\queue\console\controllers\QueueController' ], ... ];

Examples of using queue controller:

# Process a job from default queue and than exit the process ./yii queue/work # continuously process jobs from default queue ./yii queue/listen # process a job from specific queue and than exit the process ./yii queue/work myQueue # continuously process jobs from specific queue ./yii queue/listen myQueue