code: public function create()
      {
          $conn = new \AMQPConnection($this->connectionArguments);
          if (!$conn->isConnected()) {
              $conn->connect();
          }
  
          return $conn;
      }
docs: Create a new connected @see \AMQPConnection instance.
  
  @return \AMQPConnection