MessageBus.php

См. документацию.

<?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;

class MessageBus
{
    public function __construct(private readonly BrokerManager $brokerManager)
    {
    }

    public function send(MessageInterface $message, string $queueId, array $params = []): void
    {
        $broker = $this->brokerManager->getBroker($queueId);
 
        $broker->send($message, $queueId, $params);
    }
}