summaryrefslogtreecommitdiff
path: root/qpid/python
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/python')
-rwxr-xr-xqpid/python/commands/qpid-route11
1 files changed, 7 insertions, 4 deletions
diff --git a/qpid/python/commands/qpid-route b/qpid/python/commands/qpid-route
index 8077e95278..d7140d5e4b 100755
--- a/qpid/python/commands/qpid-route
+++ b/qpid/python/commands/qpid-route
@@ -50,6 +50,7 @@ _verbose = False
_quiet = False
_durable = False
_dellink = False
+_transport = "tcp"
class RouteManager:
def __init__ (self, destBroker):
@@ -84,8 +85,9 @@ class RouteManager:
mech = "ANONYMOUS"
else:
mech = "PLAIN"
- res = broker.connect(self.src.host, self.src.port, False, _durable,
- mech, self.src.authName, self.src.authPass)
+ res = broker.connect(self.src.host, self.src.port, _durable,
+ mech, self.src.authName, self.src.authPass,
+ _transport)
if _verbose:
print "Connect method returned:", res.status, res.text
link = self.getLink()
@@ -131,8 +133,9 @@ class RouteManager:
mech = "ANONYMOUS"
else:
mech = "PLAIN"
- res = broker.connect(self.src.host, self.src.port, False, _durable,
- mech, self.src.authName, self.src.authPass)
+ res = broker.connect(self.src.host, self.src.port, _durable,
+ mech, self.src.authName, self.src.authPass,
+ _transport)
if _verbose:
print "Connect method returned:", res.status, res.text
link = self.getLink()