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