RuleMaster::getMessages

private function getMessages(): Generator
{
	do
	{
		$messages = $this->getMessageMapper()->getMap(
			[
				'>ID' => $this->getLastProcessedId(),
			],
			self::PACK_SIZE,
			[
				'ID' => 'ASC',
			],
		);
		/** @var Message $message */
		foreach ($messages as $message)
		{
			yield $message;
			$this->setLastProcessedId($message->getId());
		}
	}

	while($messages->count());
}