added SSL support to API

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@929717 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 10 insertions, 9 deletions

diff --git a/python/qpid/tests/messaging/endpoints.py b/python/qpid/tests/messaging/endpoints.py
index b1f00b680c..aced76feac 100644
--- a/python/qpid/tests/messaging/endpoints.py
+++ b/python/qpid/tests/messaging/endpoints.py
@@ -30,13 +30,13 @@ class SetupTests(Base):
   def testOpen(self):
     # XXX: need to flesh out URL support/syntax
     self.conn = Connection.open(self.broker.host, self.broker.port,
-                                reconnect=self.reconnect())
+                                **self.connection_options())
     self.ping(self.conn.session())
 
   def testConnect(self):
     # XXX: need to flesh out URL support/syntax
     self.conn = Connection(self.broker.host, self.broker.port,
-                           reconnect=self.reconnect())
+                           **self.connection_options())
     self.conn.connect()
     self.ping(self.conn.session())
 
@@ -65,7 +65,8 @@ class SetupTests(Base):
       for i in range(32):
         if fds: os.close(fds.pop())
       for i in xrange(64):
-        conn = Connection.open(self.broker.host, self.broker.port)
+        conn = Connection.open(self.broker.host, self.broker.port,
+                               **self.connection_options())
         conn.close()
     finally:
       while fds:
@@ -75,7 +76,7 @@ class ConnectionTests(Base):
 
   def setup_connection(self):
     return Connection.open(self.broker.host, self.broker.port,
-                           reconnect=self.reconnect())
+                           **self.connection_options())
 
   def testSessionAnon(self):
     ssn1 = self.conn.session()
@@ -118,7 +119,7 @@ class SessionTests(Base):
 
   def setup_connection(self):
     return Connection.open(self.broker.host, self.broker.port,
-                           reconnect=self.reconnect())
+                           **self.connection_options())
 
   def setup_session(self):
     return self.conn.session()
@@ -405,7 +406,7 @@ class ReceiverTests(Base):
 
   def setup_connection(self):
     return Connection.open(self.broker.host, self.broker.port,
-                           reconnect=self.reconnect())
+                           **self.connection_options())
 
   def setup_session(self):
     return self.conn.session()
@@ -575,7 +576,7 @@ class AddressTests(Base):
 
   def setup_connection(self):
     return Connection.open(self.broker.host, self.broker.port,
-                           reconnect=self.reconnect())
+                           **self.connection_options())
 
   def setup_session(self):
     return self.conn.session()
@@ -846,7 +847,7 @@ class AddressErrorTests(Base):
 
   def setup_connection(self):
     return Connection.open(self.broker.host, self.broker.port,
-                           reconnect=self.reconnect())
+                           **self.connection_options())
 
   def setup_session(self):
     return self.conn.session()
@@ -913,7 +914,7 @@ class SenderTests(Base):
 
   def setup_connection(self):
     return Connection.open(self.broker.host, self.broker.port,
-                           reconnect=self.reconnect())
+                           **self.connection_options())
 
   def setup_session(self):
     return self.conn.session()