diff options
| author | Nuno Santos <nsantos@apache.org> | 2008-05-13 15:30:13 +0000 |
|---|---|---|
| committer | Nuno Santos <nsantos@apache.org> | 2008-05-13 15:30:13 +0000 |
| commit | 6a069879e4d88485ad5dccfeeb7acf521abc24f8 (patch) | |
| tree | 412f38aa657f21a8d523dac958a5183b82ac7a7c /python/qpid/management.py | |
| parent | 2dc2cc4a04f7cbb0707c4816733b4b47886232a6 (diff) | |
| download | qpid-python-6a069879e4d88485ad5dccfeeb7acf521abc24f8.tar.gz | |
QPID-1052: Management: session.name matches session id provided by API, handling of lost connections -- applied patch supplied by Ted Ross
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@655915 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/qpid/management.py')
| -rw-r--r-- | python/qpid/management.py | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/python/qpid/management.py b/python/qpid/management.py index 0e7233fad2..fe980b4a02 100644 --- a/python/qpid/management.py +++ b/python/qpid/management.py @@ -96,6 +96,7 @@ class managementChannel: self.ecb = exceptionCb self.context = cbContext self.reqsOutstanding = 0 + self.brokerInfo = None ssn.queue_declare (queue=self.topicName, exclusive=True, auto_delete=True) ssn.queue_declare (queue=self.replyName, exclusive=True, auto_delete=True) @@ -116,6 +117,9 @@ class managementChannel: ssn.message_flow (destination="rdest", unit=0, value=0xFFFFFFFF) ssn.message_flow (destination="rdest", unit=1, value=0xFFFFFFFF) + def setBrokerInfo (self, data): + self.brokerInfo = data + def shutdown (self): self.enabled = False self.ssn.message_cancel (destination="tdest") @@ -229,7 +233,7 @@ class managementClient: self.cv.acquire () if channel.reqsOutstanding == 0: self.cv.release () - return + return channel.brokerInfo self.syncInFlight = True starttime = time () @@ -239,6 +243,7 @@ class managementClient: self.cv.release () raise RuntimeError ("Timed out waiting for response on channel") self.cv.release () + return channel.brokerInfo def syncCallMethod (self, channel, objId, className, methodName, args=None): """ Synchronous (blocking) method call """ @@ -492,9 +497,10 @@ class managementClient: self.ctrlCb (ch.context, self.CTRL_USER, data) def handleBrokerResponse (self, ch, codec): + uuid = codec.read_uuid () + data = (uuid, ch.sessionId) + ch.setBrokerInfo (data) if self.ctrlCb != None: - uuid = codec.read_uuid () - data = (uuid, ch.sessionId) self.ctrlCb (ch.context, self.CTRL_BROKER_INFO, data) # Send a package request |