From e48979cba21658045c8ccb7fd17a8fb354fd7984 Mon Sep 17 00:00:00 2001 From: "Carl C. Trieloff" Date: Thu, 24 Apr 2008 15:24:51 +0000 Subject: QPID-953 from tross git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@651290 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/python/commands/qpid-config | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) (limited to 'qpid/python/commands/qpid-config') diff --git a/qpid/python/commands/qpid-config b/qpid/python/commands/qpid-config index 20b08933a4..03a0fd8538 100755 --- a/qpid/python/commands/qpid-config +++ b/qpid/python/commands/qpid-config @@ -19,7 +19,7 @@ # under the License. # -import os, uuid +import os import getopt import sys import socket @@ -97,10 +97,11 @@ class BrokerManager: def ConnectToBroker (self): try: self.spec = qpid.spec.load (_specpath) + self.sessionId = "%s.%d" % (os.uname()[1], os.getpid()) self.conn = Connection (connect (self.broker.host, self.broker.port), self.spec) self.conn.start () self.mclient = managementClient (self.spec) - self.mchannel = self.mclient.addChannel (self.conn.session(str(uuid.uuid4()))) + self.mchannel = self.mclient.addChannel (self.conn.session(self.sessionId)) except socket.error, e: print "Socket Error:", e sys.exit (1) @@ -108,6 +109,9 @@ class BrokerManager: print "Connect Failed:", e sys.exit (1) + def Disconnect (self): + self.mclient.removeChannel (self.mchannel) + def Overview (self): self.ConnectToBroker () mc = self.mclient @@ -374,4 +378,4 @@ else: bm.Unbind (cargs[1:]) else: Usage () - +bm.Disconnect() -- cgit v1.2.1