RuleExample::getTargetQueue

protected function getTargetQueue(Message $message): ?Queue
{
	$routingKey = $message->getHeaders()[Dictionary::HEADER_KEYS['routingKey']] ?? null;
	if ($routingKey === 'example')
	{
		$queue = (new QueueFactory())->getById(QueueRegistry::QUEUE_LIST['Example']);
		return $queue;
	}

	return null;
}