protected function runWorker($connection, $queue)
    {
        foreach (explode(',', $queue) as $tube) {
            $this->worker->eyeQueues[] = Queue::firstOrCreate(['connection' => $connection,
                                                               'tube' => $tube,
                                                               'driver' => $this->getDriverName($connection),
                                                               'healthy' => 1]);
        }

        return parent::runWorker($connection, $queue);
    }
protected function runWorker($connection, $queue)
    {
        foreach (explode(',', $queue) as $tube) {
            $this->worker->eyeQueues[] = Queue::firstOrCreate(['connection' => $connection,
                                                               'tube' => $tube,
                                                               'driver' => $this->getDriverName($connection),
                                                               'healthy' => 1]);
        }

        return parent::runWorker($connection, $queue);
    }
protected function runWorker ( $ connection , $ queue ) { foreach ( explode ( ',' , $ queue ) as $ tube ) { $ this -> worker -> eyeQueues [ ] = Queue :: firstOrCreate ( [ 'connection' => $ connection , 'tube' => $ tube , 'driver' => $ this -> getDriverName ( $ connection ) , 'healthy' => 1 ] ) ; } return parent :: runWorker ( $ connection , $ queue ) ; }
Here we intercept the run command and make sure we create a
model to represent each queue tube for future tracking.

@param  string  $connection
@param  string  $queue
@return array
Here we intercept the run command and make sure we create a model to represent each queue tube for future tracking .