[rhmessaging-commits] rhmessaging commits: r2770 - mgmt/trunk/cumin/python/cumin.

[rhmessaging-commits at lists.jboss.org]

Author: eallen
Date: 2008-11-08 12:52:32 -0500 (Sat, 08 Nov 2008)
New Revision: 2770

Modified:
   mgmt/trunk/cumin/python/cumin/model.py
Log:
Added missing add-link/bridge options

Modified: mgmt/trunk/cumin/python/cumin/model.py
===================================================================
--- mgmt/trunk/cumin/python/cumin/model.py	2008-11-08 17:50:53 UTC (rev 2769)
+++ mgmt/trunk/cumin/python/cumin/model.py	2008-11-08 17:52:32 UTC (rev 2770)
@@ -793,6 +793,7 @@
             reg = args["reg"]
             username = args["username"]
             password = args["password"]
+            transport = args["transport"]
             if username == "anonymous":
                 authMechanism = "ANONYMOUS"
             else:
@@ -800,8 +801,8 @@
 
             broker = reg._get_broker()
             broker.connect(self.model.data, completion, 
-                        link.host, link.port, link.useSsl, link.durable,
-                        authMechanism, username, password)
+                        link.host, link.port, link.durable,
+                        authMechanism, username, password, transport)
             
     class AddQueue(CuminAction):
         FILECOUNT = "qpid.file_count"
@@ -1520,13 +1521,12 @@
             dest = args["exchange"] # see qpid-route
             key = args["key"]
             tag = args["tag"]
+            dynamic = args["dynamic"]
             excludes = args["excludes"]
-            srcIsQueue = 0
-            srcIsLocal = 0
             
             link.bridge(self.model.data, completion, 
                         durable, src, dest, key, 
-                        tag, excludes, srcIsQueue, srcIsLocal)
+                        tag, excludes, False, False, dynamic)
     
     class Close(CuminAction):
         def show(self, session, link):