protected function _startWorker()
    {
        $worker = new Worker($this->queues);
        $worker->logLevel = $this->logLevel;
        fwrite(STDOUT, '*** Starting worker ' . $worker . PHP_EOL);
        $worker->work($this->interval);
    }
protected function _startWorker()
    {
        $worker = new Worker($this->queues);
        $worker->logLevel = $this->logLevel;
        fwrite(STDOUT, '*** Starting worker ' . $worker . PHP_EOL);
        $worker->work($this->interval);
    }
protected function _startWorker ( ) { $ worker = new Worker ( $ this -> queues ) ; $ worker -> logLevel = $ this -> logLevel ; fwrite ( STDOUT , '*** Starting worker ' . $ worker . PHP_EOL ) ; $ worker -> work ( $ this -> interval ) ; }
Start a worker
Start a worker