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