consumer.php

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

<?php
 
namespace Bitrix\Calendar\Core\Queue\Interfaces;
 
interface Consumer
{
    public function getQueue(): Queue;

    public function receive(): ?Message;

    public function acknowledge(Message $message): void;

    public function reject(Message $message, bool $requeue = false): void;
}