src/Server/Asyn/AMQP/SwooleIO.php
public function connect()
    {
        $sock = new Swoole\Coroutine\Client(SWOOLE_SOCK_TCP);
        if (!$sock->connect($this->host, $this->port, $this->connection_timeout))
        {
            throw new AMQPRuntimeException(
                sprintf(
                    'Error Connecting to server(%s): %s ',
                    $sock->errCode,
                    swoole_strerror($sock->errCode)
                ),
                $sock->errCode
            );
        }
        $this->sock = $sock;
    }
public function connect()
    {
        $sock = new Swoole\Coroutine\Client(SWOOLE_SOCK_TCP);
        if (!$sock->connect($this->host, $this->port, $this->connection_timeout))
        {
            throw new AMQPRuntimeException(
                sprintf(
                    'Error Connecting to server(%s): %s ',
                    $sock->errCode,
                    swoole_strerror($sock->errCode)
                ),
                $sock->errCode
            );
        }
        $this->sock = $sock;
    }
public function connect ( ) { $ sock = new Swoole \ Coroutine \ Client ( SWOOLE_SOCK_TCP ) ; if ( ! $ sock -> connect ( $ this -> host , $ this -> port , $ this -> connection_timeout ) ) { throw new AMQPRuntimeException ( sprintf ( 'Error Connecting to server(%s): %s ' , $ sock -> errCode , swoole_strerror ( $ sock -> errCode ) ) , $ sock -> errCode ) ; } $ this -> sock = $ sock ; }
Sets up the stream connection

@throws \PhpAmqpLib\Exception\AMQPRuntimeException
@throws \Exception
Sets up the stream connection