• Модуль: calendar
  • Путь к файлу: ~/bitrix/modules/calendar/lib/watcher/membership/handler/handler.php
  • Класс: BitrixCalendarWatcherMembershipHandlerHandler
  • Вызов: Handler::sendBatchOfMessagesToQueue
static function sendBatchOfMessagesToQueue(array $data): void
{
	$messages = [];
	foreach ($data as $datum)
	{
		if (!empty($datum['entityType']) && !empty($datum['entityId']))
		{
			$messages[] = (new BitrixCalendarCoreQueueMessageMessage())
				->setBody([
					'entityType' => $datum['entityType'],
					'entityId' => $datum['entityId'],
				])
				->setRoutingKey('calendar:find_events_with_entity_attendees')
			;
		}
	}

	(new BitrixCalendarCoreQueueProducerProducer())->sendBatch($messages);
}