mmucklo / DtcQueueBundle

        return $jobClass;

    }

    public function getRunClass(ContainerBuilder $container)

    {

        $runClass = $container->hasParameter('dtc_queue.class_run') ? $container->getParameter('dtc_queue.class_run') : null;

        if (!$runClass) {

            switch ($defaultType = $container->getParameter('dtc_queue.default_manager')) {

                case 'mongodb':

                    $runClass = 'Dtc\\QueueBundle\\Document\\Run';

                    break;

                case 'orm':

                    $runClass = 'Dtc\\QueueBundle\\Entity\\Run';

                    break;

                default:

                    $runClass = 'Dtc\\QueueBundle\\Model\\Run';

            }

        }

        if (isset($runClass)) {

            if (!class_exists($runClass)) {

                throw new \Exception("Can't find Run class $runClass");

            }

        }

        $test = new $runClass();

        if (!$test instanceof Run) {

            throw new \Exception("$runClass must be instance of (or derived from) Dtc\\QueueBundle\\Model\\Run");

        }

        return $runClass;

    }

    public function getRunArchiveClass(ContainerBuilder $container)

    {

        return $runClass;

    }

    public function getRunArchiveClass(ContainerBuilder $container)

    {

        $runArchiveClass = $container->hasParameter('dtc_queue.class_run_archive') ? $container->getParameter('dtc_queue.class_run_archive') : null;

        if (!$runArchiveClass) {

            switch ($defaultType = $container->getParameter('dtc_queue.default_manager')) {

                case 'mongodb':

                    $runArchiveClass = 'Dtc\\QueueBundle\\Document\\RunArchive';

                    break;

                case 'orm':

                    $runArchiveClass = 'Dtc\\QueueBundle\\Entity\\RunArchive';

                    break;

                default:

                    $runArchiveClass = 'Dtc\\QueueBundle\\Model\\Run';

            }

        }

        if (isset($runArchiveClass)) {

            if (!class_exists($runArchiveClass)) {

                throw new \Exception("Can't find RunArchive class $runArchiveClass");

            }

        }

        $test = new $runArchiveClass();

        if (!$test instanceof Run) {

            throw new \Exception("$runArchiveClass must be instance of (or derived from) Dtc\\QueueBundle\\Model\\Run");

        }

        return $runArchiveClass;

    }

    /**

     * Determines the job class based on the queue manager type.