simpleQueue

Простая очередь сообщений для использования в любых сторонних компонентах.
Очередь сообщений удобно использовать в случаях, когда необходимо в одном потоке добавить сообщение о новом действии,
а в другом потоке его выполнить.
Просто пример: отправка писем. В основном процессе добавляется сообщение о новом исходящем письме, а отдельным скриптом
осуществляется отправка письма.

Использовать возможно как на уровне объектов, так и на уровне процессоров.

Подключение сервиса

Стандартный вызов:

<code>sq = $this->modx->getService(
    'simplequeue',
    'simpleQueue',
    $this->modx->getOption('simplequeue_core_path', null, $this->modx->getOption('core_path') . 'components/simplequeue/') . 'model/simplequeue/',
    array()
);
</code>

Сокращенный вызов:

<code>$sq = $modx->getService('simplequeue');
</code>

Чтобы он стал возможен, необходимо однократно выполнить код (можно в Console):

<code>$modx->addExtensionPackage('simplequeue', '[[++core_path]]components/simplequeue/model/');
</code>

Класс

sqMessage

Класс

sqLog

Процессоры

В комплекте с компонентом идут процессоры для осуществления действий с сообщениями:

Пример вызова процессора:

<code>$response = $modx->runProcessor(
    'message/update',
    array('id' => 1, 'status' => '5'),
    array('processors_path' => MODX_CORE_PATH . 'components/simplequeue/processors/');
);
</code>

При использовании процессоров автоматически создаются записи лога sqLog, сохраняющие состояние сообщений после их
сохранения.