Spiral\Queue\Core\QueueInjector::createInjection()

Complexity

Conditions	5
Paths	5

Size

Total Lines	27
Code Lines	15

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	0	Features	0

<?php
    public function createInjection(ReflectionClass $class, string $context = null): QueueInterface
    {
        if ($context === null) {
            $connection = $this->queueManager->getConnection();
        } else {
            // Get Queue by context
            try {
                $connection = $this->queueManager->getConnection($context);
            } catch (InvalidArgumentException $e) {
                // Case when context doesn't match to configured connections
                return $this->queueManager->getConnection();
            }
        }

        // User specified a specific class type
        $className = $class->getName();
        if ($className !== QueueInterface::class && !$connection instanceof $className) {
            throw new \RuntimeException(
                \sprintf(
                    "The queue obtained by the context `%s` doesn't match the type `%s`.",
                    $context,
                    $className
                )
            );
        }

        return $connection;
    }