• Модуль: calendar
  • Путь к файлу: ~/bitrix/modules/calendar/lib/core/queue/consumer/grouphash.php
  • Класс: BitrixCalendarCoreQueueConsumerGroupHash
  • Вызов: GroupHash::reject
public function reject(InterfacesMessage $message, bool $requeue = false): void
{
	global $DB;

	$id = (int)$message->getHeader(self::HANDLED_MESSAGE_HEADER_ID);
	$hash = $message->getHeader(self::HANDLED_MESSAGE_HEADER_HASH);
	if ($id && $hash)
	{
		$DB->Query("
			DELETE FROM b_calendar_queue_handled_message
			WHERE ID <= " . $id . " 
			AND HASH = '" . $hash . "'
		");

		$this->onAfterReject($message);
	}
}