BrokerInterface.php

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

<?php
 
declare(strict_types=1);
 
namespace Bitrix\Main\Messenger\Broker;
 
use Bitrix\Main\Messenger\Entity\MessageBox;
use Bitrix\Main\Messenger\Entity\MessageInterface;
use Bitrix\Main\Messenger\Entity\ProcessingParam\ProcessingParamInterface;
use Bitrix\Main\Messenger\Internals\Exception\Broker\AckFailedException;
use Bitrix\Main\Messenger\Internals\Exception\Broker\BrokerReadException;
use Bitrix\Main\Messenger\Internals\Exception\Broker\RejectFailedException;
use Bitrix\Main\Messenger\Internals\Exception\Broker\SendFailedException;

interface BrokerInterface
{
    public function get(string $queueId, int $limit = 50): iterable;

    public function getOne(string $queueId): ?MessageBox;

    public function send(MessageInterface $message, string $queueId, array $params = []): void;

    public function ack(MessageBox $message): void;

    public function reject(MessageBox $message): void;
}