for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
declare(strict_types=1);
namespace Spiral\Queue;
use Doctrine\Inflector\Inflector;
use Doctrine\Inflector\Rules\English\InflectorFactory;
use Psr\Container\ContainerInterface;
use Spiral\Core\Exception\Container\ContainerException;
use Spiral\Queue\Exception\JobException;
final class ContainerRegistry implements HandlerRegistryInterface
{
private readonly Inflector $inflector;
public function __construct(
private readonly ContainerInterface $container
) {
$this->inflector = (new InflectorFactory())->build();
inflector
Spiral\Queue\ContainerRegistry
}
public function getHandler(string $jobType): HandlerInterface
try {
$handler = $this->container->get($this->className($jobType));
} catch (ContainerException $e) {
throw new JobException($e->getMessage(), $e->getCode(), $e);
if (!$handler instanceof HandlerInterface) {
throw new JobException(\sprintf('Unable to resolve job handler for `%s`', $jobType));
return $handler;
private function className(string $jobType): string
$names = \explode('.', $jobType);
$names = \array_map(fn (string $value) => $this->inflector->classify($value), $names);
return \implode('\\', $names);
spiral /
framework
Loading history...