comodojo / extender.framework

    protected $locker;

    public function spinup() {

        $configuration = $this->getConfiguration();

        $base_path = $configuration->get('base-path');

        $lock_path = $configuration->get('run-path');

        $lock_file = "$base_path/$lock_path/queue.worker.lock";

        $this->locker = new Locker($lock_file);

        $this->locker->lock([]);

    }

    public function loop() {

    protected $wakeup_time = 0;

    public function spinup() {

        $configuration = $this->getConfiguration();

        $base_path = $configuration->get('base-path');

        $lock_path = $configuration->get('run-path');

        $lock_file = "$base_path/$lock_path/schedule.worker.lock";

        $this->locker = new Locker($lock_file);

        $this->locker->lock([]);

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

    }

    public function loop() {