| 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\Config\ConfigurationException;
use Bitrix\Main\LoaderException;
use Bitrix\Main\Messenger\Entity\MessageInterface;
use Bitrix\Main\Messenger\Entity\ProcessingParam\ProcessingParamInterface;
use Bitrix\Main\Messenger\Internals\Exception\Broker\SendFailedException;
use Bitrix\Main\SystemException;
/**
* @internal
*/
class MessageBus
{
public function __construct(private readonly BrokerManager $brokerManager)
{
}
/**
* @param MessageInterface $message
* @param string $queueId
* @param ProcessingParamInterface[] $params
*
* @throws ConfigurationException
* @throws SendFailedException
* @throws LoaderException
* @throws SystemException
*/
public function send(MessageInterface $message, string $queueId, array $params = []): void
{
$broker = $this->brokerManager->getBroker($queueId);
$broker->send($message, $queueId, $params);
}
}