dbrule.php

<?php
 
namespace Bitrix\Calendar\Core\Queue\Rule\Rules;
 
use Bitrix\Calendar\Core\Base\Result;
use Bitrix\Calendar\Core\Queue\Interfaces;
use Bitrix\Calendar\Core\Queue\Message\HandledMessage;
use Bitrix\Calendar\Core;
use Bitrix\Calendar\Core\Queue\Queue\Queue;
 
abstract class DbRule implements Interfaces\RouteRule
{
    public function route(Interfaces\Message $message): ?HandledMessage
    {
        if ($queue = $this->getTargetQueue($message))
        {
            return (new HandledMessage())
                ->setMessage($message)
                ->setQueue($queue)
                ->setHash($this->getMessageHash($message));
        }
 
        return null;
    }
 
    abstract protected function getTargetQueue(Interfaces\Message $message): ?Queue;
 
    abstract protected function getMessageHash(Interfaces\Message $message): string;
}