Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 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();
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement