public function setBlocking($blocking)
    {
        if ($this->status != self::STATUS_NEW) {
            throw new \RuntimeException('Cannot set worker blocking after worker has started working');
        }

        $this->blocking = (bool)$blocking;
    }
public function setBlocking($blocking)
    {
        if ($this->status != self::STATUS_NEW) {
            throw new \RuntimeException('Cannot set worker blocking after worker has started working');
        }

        $this->blocking = (bool)$blocking;
    }
public function setBlocking ( $ blocking ) { if ( $ this -> status != self :: STATUS_NEW ) { throw new \ RuntimeException ( 'Cannot set worker blocking after worker has started working' ) ; } $ this -> blocking = ( bool ) $ blocking ; }
Set the queue blocking

@param bool $blocking Should worker use Redis blocking
Set the queue blocking