summaryrefslogtreecommitdiff
path: root/python/qpid/managementdata.py
diff options
context:
space:
mode:
authorCarl C. Trieloff <cctrieloff@apache.org>2008-04-24 15:24:51 +0000
committerCarl C. Trieloff <cctrieloff@apache.org>2008-04-24 15:24:51 +0000
commit841ceb18e777e49ccddc189419265f5e0b20fedf (patch)
treecdd95ace16bdd35e40970ee6861f8b8e1c67c0ea /python/qpid/managementdata.py
parentd42b7bc8854f30c397c65641bc7adaeb21808e21 (diff)
downloadqpid-python-841ceb18e777e49ccddc189419265f5e0b20fedf.tar.gz
QPID-953 from tross
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@651290 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/qpid/managementdata.py')
-rw-r--r--python/qpid/managementdata.py10
1 files changed, 7 insertions, 3 deletions
diff --git a/python/qpid/managementdata.py b/python/qpid/managementdata.py
index 327ae96a26..c908483354 100644
--- a/python/qpid/managementdata.py
+++ b/python/qpid/managementdata.py
@@ -22,7 +22,7 @@
import qpid
import socket
import struct
-import uuid
+import os
from qpid.management import managementChannel, managementClient
from threading import Lock
from disp import Display
@@ -171,6 +171,7 @@ class ManagementData:
self.lastUnit = None
self.methodSeq = 1
self.methodsPending = {}
+ self.sessionId = "%s.%d" % (os.uname()[1], os.getpid())
self.broker = Broker (host)
self.conn = Connection (connect (self.broker.host, self.broker.port), self.spec)
@@ -179,10 +180,10 @@ class ManagementData:
self.mclient = managementClient (self.spec, self.ctrlHandler, self.configHandler,
self.instHandler, self.methodReply)
self.mclient.schemaListener (self.schemaHandler)
- self.mch = self.mclient.addChannel (self.conn.session(str(uuid.uuid4())))
+ self.mch = self.mclient.addChannel (self.conn.session(self.sessionId))
def close (self):
- self.mclient.removeChannel (self.mch)
+ pass
def refName (self, oid):
if oid == 0:
@@ -626,3 +627,6 @@ class ManagementData:
methodName = tokens[1]
args = tokens[2:]
self.callMethod (userOid, methodName, args)
+
+ def do_exit (self):
+ self.mclient.removeChannel (self.mch)