def connect()

in qpid/testlib.py [0:0]


    def connect(self, host=None, port=None, user=None, password=None, tune_params=None, client_properties=None, channel_options=None):
        """Create a new connction, return the Client object"""
        host = host or self.config.broker.host
        port = port or self.config.broker.port or self.DEFAULT_PORT
        user = user or self.config.broker.user or self.DEFAULT_USERNAME
        password = password or self.config.broker.password or self.DEFAULT_PASSWORD
        client = qpid.client.Client(host, port)
        try:
          client.start(username = user, password=password, tune_params=tune_params, client_properties=client_properties, channel_options=channel_options)
        except qpid.client.Closed as e:
            if isinstance(e.args[0], VersionError):
                raise Skipped(e.args[0])
            else:
                raise e
        except socket.error as e:
            raise Skipped(e)
        return client