recipientbuilderjob.php

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

<?php
 
namespace Bitrix\Sender\Runtime;
 
use Bitrix\Main\Type\DateTime;

class RecipientBuilderJob extends Job
{
    public static function addEventAgent(int $postingId)
    {
        (new SegmentDataBuilderJob())->addAgent(
            static::getAgentName((int)$postingId),
            60,
            (new DateTime())->add('+60 seconds')
        );
    }

    public static function removeAgentFromDB(int $postingId)
    {
        (new SegmentDataBuilderJob())->removeAgent(
            static::getAgentName((int)$postingId)
        );
    }

    public static function getAgentName(int $postingId)
    {
        return "\Bitrix\Sender\Runtime\RecipientBuilderJob::runAgent({$postingId});";
    }
 
    public static function runAgent(int $postingId)
    {
        $builder = new \Bitrix\Sender\Posting\Builder($postingId);
 
        if (!$builder->isResult())
        {
            return self::getAgentName($postingId);
        }
 
        return '';
    }
}