summaryrefslogtreecommitdiff
path: root/python
diff options
context:
space:
mode:
authorTed Ross <tross@apache.org>2008-05-21 21:40:49 +0000
committerTed Ross <tross@apache.org>2008-05-21 21:40:49 +0000
commit35d9dc572a918015c038245725b0f9894b13132a (patch)
treed9efecaeab11e12f0b2f2d87ff7f202383eaa6a0 /python
parent28404c0026b5bed8ad4ad37d52cd4d3aab5c70bc (diff)
downloadqpid-python-35d9dc572a918015c038245725b0f9894b13132a.tar.gz
QPID-1087
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@658886 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python')
-rwxr-xr-xpython/commands/qpid-route18
1 files changed, 12 insertions, 6 deletions
diff --git a/python/commands/qpid-route b/python/commands/qpid-route
index 0dc9a89f21..5206f5c3cb 100755
--- a/python/commands/qpid-route
+++ b/python/commands/qpid-route
@@ -112,9 +112,12 @@ class RouteManager:
connectArgs["port"] = self.src.port
connectArgs["useSsl"] = False
connectArgs["durable"] = _durable
- connectArgs["authMechanism"] = "PLAIN"
- connectArgs["username"] = self.src.username
- connectArgs["password"] = self.src.password
+ if self.src.username == "anonymous":
+ connectArgs["authMechanism"] = "ANONYMOUS"
+ else:
+ connectArgs["authMechanism"] = "PLAIN"
+ connectArgs["username"] = self.src.username
+ connectArgs["password"] = self.src.password
res = mc.syncCallMethod (self.mch, broker.id, broker.classKey, "connect", connectArgs)
if _verbose:
print "Connect method returned:", res.status, res.statusText
@@ -164,9 +167,12 @@ class RouteManager:
connectArgs["port"] = self.src.port
connectArgs["useSsl"] = False
connectArgs["durable"] = _durable
- connectArgs["authMechanism"] = "PLAIN"
- connectArgs["username"] = self.src.username
- connectArgs["password"] = self.src.password
+ if self.src.username == "anonymous":
+ connectArgs["authMechanism"] = "ANONYMOUS"
+ else:
+ connectArgs["authMechanism"] = "PLAIN"
+ connectArgs["username"] = self.src.username
+ connectArgs["password"] = self.src.password
res = mc.syncCallMethod (self.mch, broker.id, broker.classKey, "connect", connectArgs)
if _verbose:
print "Connect method returned:", res.status, res.statusText