src/LazyConnection.php
public function create()
    {
        $conn = new \AMQPConnection($this->connectionArguments);
        if (!$conn->isConnected()) {
            $conn->connect();
        }

        return $conn;
    }
public function create()
    {
        $conn = new \AMQPConnection($this->connectionArguments);
        if (!$conn->isConnected()) {
            $conn->connect();
        }

        return $conn;
    }
Create a new connected @see \AMQPConnection instance.

@return \AMQPConnection