You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by tr...@apache.org on 2008/09/19 00:19:22 UTC
svn commit: r696833 - /incubator/qpid/trunk/qpid/python/qpid/qmfconsole.py
Author: tross
Date: Thu Sep 18 15:19:22 2008
New Revision: 696833
URL: http://svn.apache.org/viewvc?rev=696833&view=rev
Log:
QPID-1288 - Removed test code
Modified:
incubator/qpid/trunk/qpid/python/qpid/qmfconsole.py
Modified: incubator/qpid/trunk/qpid/python/qpid/qmfconsole.py
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/qpid/qmfconsole.py?rev=696833&r1=696832&r2=696833&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/python/qpid/qmfconsole.py (original)
+++ incubator/qpid/trunk/qpid/python/qpid/qmfconsole.py Thu Sep 18 15:19:22 2008
@@ -52,9 +52,7 @@
def objectProps(self, broker, id, record):
""" Invoked when an object is updated. """
- global B
- if record.getClassKey()[1] == "broker":
- B = record
+ pass
def objectStats(self, broker, id, record):
""" Invoked when an object is updated. """
@@ -877,7 +875,7 @@
def _decOutstanding(self):
self.cv.acquire()
self.reqsOutstanding -= 1
- if self.reqsOutstanding == 0 and not self.topicBound and self.session != None:
+ if self.reqsOutstanding == 0 and not self.topicBound and self.session.console != None:
self.topicBound = True
self.amqpSession.exchange_bind(exchange="qpid.management", queue=self.topicName, binding_key="mgmt.#")
if self.reqsOutstanding == 0 and self.syncInFlight:
@@ -945,9 +943,9 @@
# TEST
-c = Console()
-s = Session(c)
-b = s.addBroker()
-cl = s.getClasses("org.apache.qpid.broker")
-sch = s.getSchema(cl[0])
+#c = Console()
+#s = Session(c)
+#b = s.addBroker()
+#cl = s.getClasses("org.apache.qpid.broker")
+#sch = s.getSchema(cl[0])