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