diff options
| author | Gordon Sim <gsim@apache.org> | 2008-05-12 19:45:22 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2008-05-12 19:45:22 +0000 |
| commit | 6f145c117cebc1c75e993ad67facd11b8363f3c9 (patch) | |
| tree | 05f02953d4ae7e9533b0dfccdf44a3f609ec8ef4 /python/qpid/managementdata.py | |
| parent | 277e5e1f1e7bc26e2c8aff065e84ef0861a851c2 (diff) | |
| download | qpid-python-6f145c117cebc1c75e993ad67facd11b8363f3c9.tar.gz | |
QPID-1052: Patch from Ted Ross
This patch contains the following:
1) The session-id reported by the management API now matches the session.name in the session table
2) management.py API has a new callback for closed connections
3) qpid-tool uses the closed-connection handler to notify the user of a lost connection
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@655619 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/qpid/managementdata.py')
| -rw-r--r-- | python/qpid/managementdata.py | 13 |
1 files changed, 12 insertions, 1 deletions
diff --git a/python/qpid/managementdata.py b/python/qpid/managementdata.py index 1d99cc11bc..bdc299767d 100644 --- a/python/qpid/managementdata.py +++ b/python/qpid/managementdata.py @@ -160,11 +160,20 @@ class ManagementData: finally: self.lock.release () + def closeHandler (self, reason): + print "Connection to broker lost:", reason + self.operational = False + if self.cli != None: + self.cli.setPromptMessage ("Broker Disconnected") + def schemaHandler (self, context, className, configs, insts, methods, events): """ Callback for schema updates """ if className not in self.schema: self.schema[className] = (configs, insts, methods, events) + def setCli (self, cliobj): + self.cli = cliobj + def __init__ (self, disp, host, username="guest", password="guest", specfile="../../specs/amqp.0-10.xml"): self.spec = qpid.spec.load (specfile) @@ -184,9 +193,11 @@ class ManagementData: self.conn.start () self.mclient = managementClient (self.spec, self.ctrlHandler, self.configHandler, - self.instHandler, self.methodReply) + self.instHandler, self.methodReply, self.closeHandler) self.mclient.schemaListener (self.schemaHandler) self.mch = self.mclient.addChannel (self.conn.session(self.sessionId)) + self.operational = True + self.cli = None def close (self): pass |