Update AsyncWorkerCommand.php

Fix component name for daemon.
bazilio91 · Nov 15, 2015 · 1d3a6a8 · 1d3a6a8
1 parent 6689ea2
commit 1d3a6a8
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/commands/AsyncWorkerCommand.php b/commands/AsyncWorkerCommand.php
@@ -24,9 +24,9 @@ public function actionExecute($queueName = null)
     public function actionDaemon($queueName = null)
     {
         /** @var AsyncTask $task */
-        while ($task = \Yii::$app->asyncAmqp->waitAndReceive($queueName ?: AsyncTask::$queueName)) {
+        while ($task = \Yii::$app->async->waitAndReceive($queueName ?: AsyncTask::$queueName)) {
             $task->execute();
-            \Yii::$app->asyncAmqp->acknowledgeTask($task);
+            \Yii::$app->async->acknowledgeTask($task);
         }
     }
 }