public function actionIndex()
    {
        $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
        $channel = $connection->channel();

        $channel->queue_declare('calllist', false, false, false, false);
        $channel->basic_consume('calllist', '', false, true, false, false, function ($msg) {
            $message = json_decode($msg->body);
            /**
             * @var CampaignList $campaignList
             * @var CampaignProcess $process
             */
            $campaignList = CampaignList::find()->where(['id' => $message->campaign_list_id])->one();
            if ($campaignList !== null) {
                try {
                    $preparer = Preparer::create($campaignList);
                    $statusData = $preparer->prepare();
                    $process = $campaignList->getProcess();
                    $process->updateStatus($statusData);
                } catch (Throwable $e) {
                    $domain = $campaignList->getCampaign()->getDomain();
                    $logger = new Logger('calllist');
                    $logger->pushHandler(
                        new StreamHandler(Yii::$app->params['app_dir'] . '/../logs/command/' . $domain->getName() . '.log', Logger::ERROR)
                    );
                    $logger->error('CampaignList(' . $message->campaign_list_id . ') ' . get_class($e) . ' - message -> ' . $e->getMessage());
                    $logger->error('CampaignList(' . $message->campaign_list_id . ') ' . get_class($e) . ' - trace -> ' . $e->getTraceAsString());

                    Crier::run(
                        'ERROR IN CALL LIST SERVICE' . PHP_EOL . PHP_EOL .
                        'Domain: ' . $domain->name . PHP_EOL .
                        'campaign_list_id: ' . $campaignList->getId() . PHP_EOL .
                        'Message: ' . $e->getMessage() . PHP_EOL .
                        'Trace:' . PHP_EOL . PHP_EOL . $e->getTraceAsString()
                    );
                }
            }
        });

        while (count($channel->callbacks)) {
            $channel->wait();
        }
    }