From 46b5fe1ed0169a36744f542c8f646609a83490f6 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Mon, 13 Oct 2008 16:43:10 +0000 Subject: Allow management clienst to specify transport to use for inter-broker links git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@704159 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/python/commands/qpid-route | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) (limited to 'qpid/python') 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() -- cgit v1.2.1