examplerule.php

<?php
 
namespace Bitrix\Calendar\Core\Queue\Rule\Rules;
 
use Bitrix;
use Bitrix\Calendar\Core\Queue\Interfaces;
use Bitrix\Calendar\Core\Queue\Message\Dictionary;
use Bitrix\Calendar\Core\Queue\Queue\Queue;
use Bitrix\Calendar\Core\Queue\Queue\QueueFactory;
use Bitrix\Calendar\Core\Queue\Queue\QueueRegistry;
use Bitrix\Calendar\Core\Queue\Rule\WakeUpAgentTrait;
 
class ExampleRule extends DbRule
{
    use WakeUpAgentTrait;
 
    protected function getTargetQueue(Interfaces\Message $message): ?Queue
    {
        $routingKey = $message->getHeaders()[Dictionary::HEADER_KEYS['routingKey']] ?? null;
        if ($routingKey === 'example.test')
        {
            $queue = (new QueueFactory())->getById(QueueRegistry::QUEUE_LIST['EventDelayedSync']);
            return $queue;
        }
 
        return null;
    }
 
    protected function getMessageHash(Interfaces\Message $message): string
    {
        return 'ExamplePrefix_' . $message->getBody()['exampleField'];
    }
 
    protected function handleRuleMasterFinish(Bitrix\Main\Event $event): Bitrix\Main\EventResult
    {
        $result = $this->wakeupAgent('Name of agent');
        if ($result->isSuccess())
        {
            $result = new Bitrix\Main\EventResult(Bitrix\Main\EventResult::SUCCESS, []);
        }
        else
        {
            $result = new Bitrix\Main\EventResult(Bitrix\Main\EventResult::ERROR, []);
        }
 
        return $result;
    }
}