| Server IP : 80.87.202.40 / Your IP : 216.73.216.169 Web Server : Apache System : Linux rospirotorg.ru 5.14.0-539.el9.x86_64 #1 SMP PREEMPT_DYNAMIC Thu Dec 5 22:26:13 UTC 2024 x86_64 User : bitrix ( 600) PHP Version : 8.2.27 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /home/bitrix/ext_www/rospirotorg.ru/bitrix/modules/main/lib/Messenger/Internals/ |
Upload File : |
<?php
declare(strict_types=1);
namespace Bitrix\Main\Messenger\Internals;
use Bitrix\Main\Application;
use Bitrix\Main\Config\ConfigurationException;
use Bitrix\Main\DI\ServiceLocator;
use Bitrix\Main\LoaderException;
use Bitrix\Main\Messenger\Internals\Config\QueueConfigRegistry;
use Bitrix\Main\Messenger\Internals\Exception\ReceiverException;
use Bitrix\Main\SystemException;
final class Worker
{
/**
* @throws LoaderException
* @throws ConfigurationException
* @throws SystemException
*/
public function process(array $options = []): void
{
$registry = ServiceLocator::getInstance()->get(QueueConfigRegistry::class);
$queues = $registry->getQueues();
if (!empty($options['queues']))
{
$queues = array_intersect_key($queues, array_combine($options['queues'], $options['queues']));
}
foreach ($queues as $queueConfig)
{
try
{
$queueConfig->createReceiver()->run();
}
catch (ReceiverException $e)
{
Application::getInstance()->getExceptionHandler()->writeToLog($e);
}
}
}
}