agentlistener.php

<?php
 
namespace Bitrix\Calendar\Core\Queue\QueueListener;
 
use Bitrix\Calendar\Core\Queue\Agent\AgentEntity;
use Bitrix;
use Bitrix\Calendar\Core\Queue;
use CAgent;
 
class AgentListener implements Queue\Interfaces\Listener
{
    private const DEFAULT_DELAY = 60; // in seconds
 
    private AgentEntity $agentEntity;
 
    public function __construct(AgentEntity $agentEntity)
    {
        $this->agentEntity = $agentEntity;
    }
 
    public function handle()
    {
        if ($agentId = $this->getAgentId())
        {
            $time = new Bitrix\Main\Type\DateTime();
 
            $delay = $this->agentEntity->getDelay() ?: self::DEFAULT_DELAY;
            $time->add($delay . ' seconds');
 
            CAgent::Update($agentId,[
                'NEXT_EXEC' => $time,
            ]);
        }
    }
 
    private function getAgentId(): ?int
    {
        $agent = CAgent::getList(
            [],
            [
                'MODULE_ID' => $this->agentEntity->getModule(),
                '=NAME' => $this->agentEntity->getName(),
            ]
        )->Fetch();
 
        if ($agent)
        {
            return $agent['ID'];
        }
 
        return null;
    }
}