DoctrineQueueFactory.php

class DoctrineQueueFactory implements FactoryInterface
{
    /**
     * {@inheritDoc}
     */
    public function createService(ServiceLocatorInterface $serviceLocator, $name = '', $requestedName = '')
    {
        $parentLocator = $serviceLocator->getServiceLocator();

        /** @var $doctrineOptions \SlmQueueDoctrine\Options\DoctrineOptions */
        $doctrineOptions = $parentLocator->get('SlmQueueDoctrine\Options\DoctrineOptions');

        /** @var $connection \Doctrine\DBAL\Connection */
        $connection       = $parentLocator->get($doctrineOptions->getConnection());
        $tableName        = $doctrineOptions->getTableName();
        $jobPluginManager = $parentLocator->get('SlmQueue\Job\JobPluginManager');

        $moduleOptions = $parentLocator->get('SlmQueue\Options\ModuleOptions');
        $queues        = $moduleOptions->getQueuesOptions();
        
        $queueOptions = new DoctrineQueueOptions(isset($queues[$requestedName]) ? $queues[$requestdNma] : array());

        $queue = new DoctrineQueue($connection, $tableName, $requestedName, $jobPluginManager);

        $config = $parentLocator->get('Config');
        $options = isset($config['slm_queue']['queues'][$requestedName]) ? $config['slm_queue']['queues'][$requestedName] : array();
        return $queue;
    }
}