src/Connection/Socket.php
public function connect()
    {
        if (!$this->connection) {
            $errNum = $errStr = null;
            $this->connection = @fsockopen($this->host, $this->port, $errNum, $errStr, $this->options['timeout']);

            if (!$this->connection or $errNum > 0) {
                $message = sprintf(
                    'Could not connect to beanstalkd "%s:%d": %s (%d)',
                    $this->host,
                    $this->port,
                    $errStr,
                    $errNum
                );
                throw new Exception\SocketException($message);
            }

            // remove timeout on the stream, allows blocking reserve
            stream_set_timeout($this->connection, -1, 0);
        }

        return $this;
    }
public function connect()
    {
        if (!$this->connection) {
            $errNum = $errStr = null;
            $this->connection = @fsockopen($this->host, $this->port, $errNum, $errStr, $this->options['timeout']);

            if (!$this->connection or $errNum > 0) {
                $message = sprintf(
                    'Could not connect to beanstalkd "%s:%d": %s (%d)',
                    $this->host,
                    $this->port,
                    $errStr,
                    $errNum
                );
                throw new Exception\SocketException($message);
            }

            // remove timeout on the stream, allows blocking reserve
            stream_set_timeout($this->connection, -1, 0);
        }

        return $this;
    }
public function connect ( ) { if ( ! $ this -> connection ) { $ errNum = $ errStr = null ; $ this -> connection = @ fsockopen ( $ this -> host , $ this -> port , $ errNum , $ errStr , $ this -> options [ 'timeout' ] ) ; if ( ! $ this -> connection or $ errNum > 0 ) { $ message = sprintf ( 'Could not connect to beanstalkd "%s:%d": %s (%d)' , $ this -> host , $ this -> port , $ errStr , $ errNum ) ; throw new Exception \ SocketException ( $ message ) ; } // remove timeout on the stream, allows blocking reserve stream_set_timeout ( $ this -> connection , - 1 , 0 ) ; } return $ this ; }
Connect the socket to the beanstalk server.

@return $this
@throws Exception\SocketException
Connect the socket to the beanstalk server .