svn commit: r711384 - /incubator/qpid/trunk/qpid/python/qpid/qmfconsole.py

[tr...@apache.org]

Author: tross
Date: Tue Nov  4 12:28:56 2008
New Revision: 711384

URL: http://svn.apache.org/viewvc?rev=711384&view=rev
Log:
Clarified broker/agent banks in method names.  Added new accessor methods for bank values

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=711384&r1=711383&r2=711384&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/python/qpid/qmfconsole.py (original)
+++ incubator/qpid/trunk/qpid/python/qpid/qmfconsole.py Tue Nov  4 12:28:56 2008
@@ -671,7 +671,7 @@
             self._encodeValue(sendCodec, argList[aIdx], arg.type)
             aIdx += 1
         smsg = broker._message(sendCodec.encoded, "agent.%d.%d" %
-                               (objectId.getBroker(), objectId.getBank()))
+                               (objectId.getBrokerBank(), objectId.getAgentBank()))
         broker._send(smsg)
         return seq
     return None
@@ -866,7 +866,7 @@
 
   def __repr__(self):
     return "%d-%d-%d-%d-%d" % (self.getFlags(), self.getSequence(),
-                               self.getBroker(), self.getBank(), self.getObject())
+                               self.getBrokerBank(), self.getAgentBank(), self.getObject())
 
   def index(self):
     return (self.first, self.second)
@@ -877,10 +877,10 @@
   def getSequence(self):
     return (self.first & 0x0FFF000000000000) >> 48
 
-  def getBroker(self):
+  def getBrokerBank(self):
     return (self.first & 0x0000FFFFF0000000) >> 28
 
-  def getBank(self):
+  def getAgentBank(self):
     return self.first & 0x000000000FFFFFFF
 
   def getObject(self):
@@ -1014,7 +1014,7 @@
             self._session._encodeValue(sendCodec, args[aIdx], arg.type)
             aIdx += 1
         smsg = self._broker._message(sendCodec.encoded, "agent.%d.%d" %
-                                     (self._objectId.getBroker(), self._objectId.getBank()))
+                                     (self._objectId.getBrokerBank(), self._objectId.getAgentBank()))
         if synchronous:
           try:
             self._broker.cv.acquire()
@@ -1109,6 +1109,9 @@
     """ Get broker's unique identifier (UUID) """
     return self.brokerId
 
+  def getBrokerBank(self):
+    return 1
+
   def getSessionId(self):
     """ Get the identifier of the AMQP session to the broker """
     return self.amqpSessionId
@@ -1316,6 +1319,9 @@
   def getBroker(self):
     return self.broker
 
+  def getAgentBank(self):
+    return self.bank
+
 class Event:
   """ """
   def __init__(self, session, broker, codec):