experimental redis pubsub support

Author: bazilio91

AsyncComponent.php

@@ -47,6 +47,10 @@ public function receiveTask($queueName)
         return $this->transport->receive($queueName);
     }
 
+    public function waitAndReceive($queueName) {
+        return $this->transport->waitAndReceive($queueName);
+    }
+
     /**
      * @param AsyncTask $task
      * @return bool

commands/AsyncWorkerCommand.php

@@ -0,0 +1,30 @@
+<?php
+
+use bazilio\async\models\AsyncTask;
+
+class AsyncWorkerCommand extends \yii\console\Controller
+{
+    /**
+     * @param string|null $queueName
+     */
+    public function actionExecute($queueName = null)
+    {
+        /** @var AsyncTask $task */
+        while ($task = \Yii::$app->async->receiveTask($queueName ?: AsyncTask::$queueName)) {
+            $task->execute();
+            \Yii::$app->async->acknowledgeTask($task);
+        }
+    }
+
+    /**
+     * @param string|null $queueName
+     */
+    public function actionDaemon($queueName = null)
+    {
+        /** @var AsyncTask $task */
+        while ($task = \Yii::$app->asyncAmqp->waitAndReceive($queueName ?: AsyncTask::$queueName)) {
+            $task->execute();
+            \Yii::$app->asyncAmqp->acknowledgeTask($task);
+        }
+    }
+}

composer.json

@@ -16,11 +16,12 @@
         "yiisoft/yii2": "*"
     },
     "require-dev": {
-        "phpunit/phpunit": "3.7.*",
+        "phpunit/phpunit": "4.6.*",
         "yiisoft/yii2-codeception": "*",
-        "codeception/codeception": "*",
+        "codeception/codeception": "2.0.*",
         "pdezwart/php-amqp": "dev-master",
-        "yiisoft/yii2-redis": "*"
+        "yiisoft/yii2-redis": "*",
+        "kriswallsmith/spork": "*"
     },
     "autoload": {
         "psr-4": {