diff options
| author | Ted Ross <tross@apache.org> | 2008-05-21 21:40:49 +0000 |
|---|---|---|
| committer | Ted Ross <tross@apache.org> | 2008-05-21 21:40:49 +0000 |
| commit | fa85fb8871a8b1e620479d0717f1655553a93223 (patch) | |
| tree | 8e81aec327fec3c10b1346e79d436b404b51bef0 /qpid/python | |
| parent | 286677e45f1d13d01c634d9e2a4a3fa42bc6709b (diff) | |
| download | qpid-python-fa85fb8871a8b1e620479d0717f1655553a93223.tar.gz | |
QPID-1087
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@658886 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/python')
| -rwxr-xr-x | qpid/python/commands/qpid-route | 18 |
1 files changed, 12 insertions, 6 deletions
diff --git a/qpid/python/commands/qpid-route b/qpid/python/commands/qpid-route index 0dc9a89f21..5206f5c3cb 100755 --- a/qpid/python/commands/qpid-route +++ b/qpid/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 |