MessengerMessageTable.php

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

<?php
 
declare(strict_types=1);
 
namespace Bitrix\Main\Messenger\Internals\Storage\Db\Model;
 
use Bitrix\Main\ORM\Data\DataManager;
use Bitrix\Main\ORM\Event;
use Bitrix\Main\ORM\EventResult;
use Bitrix\Main\ORM\Fields\IntegerField;
use Bitrix\Main\ORM\Fields\TextField;
use Bitrix\Main\ORM\Fields\DatetimeField;
use Bitrix\Main\ORM\Fields\StringField;
use Bitrix\Main\Type\DateTime;

class MessengerMessageTable extends DataManager
{
    public static function onBeforeUpdate(Event $event): EventResult
    {
        $result = new EventResult();
 
        $result->modifyFields(['UPDATED_AT' => new DateTime()]);
 
        return $result;
    }
 
    public static function getTableName(): string
    {
        return 'b_main_messenger_message';
    }
 
    public static function getMap(): array
    {
        return [
            (new IntegerField('ID'))
                ->configurePrimary()
                ->configureAutocomplete(),
 
            (new StringField('QUEUE_ID'))
                ->configureRequired()
                ->configureSize(255),
 
            (new StringField('ITEM_ID'))
                ->configureNullable()
                ->configureSize(64),
 
            (new StringField('CLASS'))
                ->configureRequired(),
 
            (new TextField('PAYLOAD'))
                ->configureRequired(),
 
            (new DatetimeField('CREATED_AT'))
                ->configureRequired()
                ->configureDefaultValueNow(),
 
            (new DatetimeField('UPDATED_AT'))
                ->configureRequired()
                ->configureDefaultValueNow(),
 
            (new IntegerField('TTL'))
                ->configureRequired(),
 
            (new DatetimeField('AVAILABLE_AT'))
                ->configureRequired()
                ->configureDefaultValue(fn() => new DateTime()),
 
            (new StringField('STATUS'))
                ->configureRequired()
                ->configureDefaultValue(MessageStatus::New->value)
                ->configureSize(10),
        ];
    }
}