<?php

/**
 * @link https://www.kuvalda.ru/
 * @copyright
 * @license
 */

namespace dominion\amqp\console;

use Yii;
use yii\console\Controller;
use yii\console\ExitCode;
use dominion\amqp\AmqpHelper;

/**
 * Работа с очередеми
 *
 * @author Rybkin Sasha <ribkin@dominion.ru>
 * @since 0.1
 */
class AmqpController extends Controller
{

    /**
     * Создать все очереди
     * @return int Exit code
     */
    public function actionCreateAllQueue()
    {
        foreach(Yii::$app->params['amqp']['projects'] as $keyProject =>$project)
        {
            $amqp = new AmqpHelper;
            $amqp->setProject($keyProject);
            foreach ($project["queues"] as $key =>$value)
            {
                $amqp->getQueueObject($key);
            }
        }
        return ExitCode::OK;
    }

}