comodojo / extender.framework

    use EntityManagerTrait;

    use WorkerTrait;

    public function spinup() {

        $this->task_manager = new TaskManager(

            'queue.worker',

            $this->getConfiguration(),

            $this->getLogger(),

            $this->getTasksTable(),

            $this->getEvents(),

            $this->getEntityManager()

        );

        $this->job_manager = new QueueManager(

            $this->getConfiguration(),

            $this->getLogger(),

            $this->getEvents(),

            $this->getEntityManager()

        );

    }

    public function loop() {

    protected $wakeup_time = 0;

    public function spinup() {

        $this->task_manager = new TaskManager(

            'schedule.worker',

            $this->getConfiguration(),

            $this->getLogger(),

            $this->getTasksTable(),

            $this->getEvents(),

            $this->getEntityManager()

        );

        $this->getEvents()->subscribe('daemon.worker.refresh', '\Comodojo\Extender\Listeners\RefreshScheduler');

        $this->job_manager = new ScheduleManager(

            $this->getConfiguration(),

            $this->getLogger(),

            $this->getEvents(),

            $this->getEntityManager()

        );

    }

    public function loop() {