protected function getNextJob($connection, $queue)
    {
        if ($this->cache) {
            foreach ($this->eyeQueues as $queue) {
                $this->eyewitnessHeartbeat($queue);
            }
        }

        foreach ($this->eyeQueues as $queue) {
            $this->currentQueue = $queue;

            $job = parent::getNextJob($connection, $queue->tube);

            if (! is_null($job)) {
                $this->eyeTube = $queue->tube;
                return $job;
            }
        }
    }
protected function getNextJob($connection, $queue)
    {
        if ($this->cache) {
            foreach ($this->eyeQueues as $queue) {
                $this->eyewitnessHeartbeat($queue);
            }
        }

        foreach ($this->eyeQueues as $queue) {
            $this->currentQueue = $queue;

            $job = parent::getNextJob($connection, $queue->tube);

            if (! is_null($job)) {
                $this->eyeTube = $queue->tube;
                return $job;
            }
        }
    }
protected function getNextJob ( $ connection , $ queue ) { if ( $ this -> cache ) { foreach ( $ this -> eyeQueues as $ queue ) { $ this -> eyewitnessHeartbeat ( $ queue ) ; } } foreach ( $ this -> eyeQueues as $ queue ) { $ this -> currentQueue = $ queue ; $ job = parent :: getNextJob ( $ connection , $ queue -> tube ) ; if ( ! is_null ( $ job ) ) { $ this -> eyeTube = $ queue -> tube ; return $ job ; } } }
Extend the worker and place a heartbeat as it is processing. Then simply "feed"
the tubes into the next job parent. This provides the exact same functionality,
but this way we know exactly which tube is processing the job.

@param  \Illuminate\Contracts\Queue\Queue  $connection
@param  string  $queue
@return \Illuminate\Contracts\Queue\Job|null
Extend the worker and place a heartbeat as it is processing . Then simply feed the tubes into the next job parent . This provides the exact same functionality but this way we know exactly which tube is processing the job .