• Модуль: calendar
  • Путь к файлу: ~/bitrix/modules/calendar/lib/core/queue/examples/processorexample.php
  • Класс: BitrixCalendarCoreQueueExamplesProcessorExample
  • Вызов: ProcessorExample::process
public function process(QueueInterfacesMessage $message): string
    {
	$body = $message->getBody();
	if ($userId = $body['userId'])
	{
		CIMNotify::Add([
			'TO_USER_ID' => $userId,
			'FROM_USER_ID' => $userId,
			'NOTIFY_TYPE' => IM_NOTIFY_SYSTEM,
			'NOTIFY_MODULE' => 'calendar',
			'NOTIFY_TAG' => 'CALENDAR|QUEUE|EXAMPLE|'.$userId,
			'NOTIFY_SUB_TAG' => 'CALENDAR|QUEUE|EXAMPLE|'.$userId,
			'NOTIFY_MESSAGE' => $body['content'],
		]);
		return self::ACK;
	}
	else
	{
		return self::REJECT;
	}
    }