diff options
author | Ted Ross <tross@apache.org> | 2008-11-04 20:28:56 +0000 |
---|---|---|
committer | Ted Ross <tross@apache.org> | 2008-11-04 20:28:56 +0000 |
commit | d93dbf035ab08a71165d9ca508fdc286d16b7b72 (patch) | |
tree | 2d713e7d8c005ab07ee98b1d6995928c3dfeb2b6 | |
parent | 06495bdb03cac9ba89589aca6d02dcaf89af2d02 (diff) | |
download | qpid-python-d93dbf035ab08a71165d9ca508fdc286d16b7b72.tar.gz |
Clarified broker/agent banks in method names. Added new accessor methods for bank values
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@711384 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r-- | python/qpid/qmfconsole.py | 16 |
1 files changed, 11 insertions, 5 deletions
diff --git a/python/qpid/qmfconsole.py b/python/qpid/qmfconsole.py index 3ceb41b7a6..e173a4b864 100644 --- a/python/qpid/qmfconsole.py +++ b/python/qpid/qmfconsole.py @@ -671,7 +671,7 @@ class Session: 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 @@ class ObjectId: 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 @@ class ObjectId: 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 @@ class Object(object): 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 @@ class Broker: """ 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 @@ class Agent: def getBroker(self): return self.broker + def getAgentBank(self): + return self.bank + class Event: """ """ def __init__(self, session, broker, codec): |