eventdelayedsyncagent.php

<?php
 
namespace Bitrix\Calendar\Core\Queue\Agent;
 
use Bitrix\Calendar\Core\Queue\Consumer;
use Bitrix\Calendar\Core\Queue\Interfaces;
use Bitrix\Calendar\Core\Queue\Processor;
use Bitrix\Calendar\Core\Queue\Queue\QueueFactory;
use Bitrix\Calendar\Core\Queue\Queue\QueueRegistry;
 
class EventDelayedSyncAgent extends BaseAgent
{
    protected function getConsumer(): Interfaces\Consumer
    {
        $queue = (new QueueFactory())->getById(QueueRegistry::QUEUE_LIST['EventDelayedSync']);
 
        return new Consumer\GroupHash($queue);
    }
 
    protected function getProcessor(): Interfaces\Processor
    {
        return new Processor\EventDelayedSync();
    }
}