diff options
| author | Ted Ross <tross@apache.org> | 2010-02-03 13:35:58 +0000 |
|---|---|---|
| committer | Ted Ross <tross@apache.org> | 2010-02-03 13:35:58 +0000 |
| commit | a3b1f4cf9b875eea454fdc883c391393d45363b7 (patch) | |
| tree | f8bdf8bb71db05306272e0df5da38014d3a273cc /cpp/include | |
| parent | b5d89088886b2d745c8bbdab747463bcd8679893 (diff) | |
| download | qpid-python-a3b1f4cf9b875eea454fdc883c391393d45363b7.tar.gz | |
Changes to management code generation:
1) Added readProperties(Buffer) method to ManagementObject to help in the
serialization and unserialization of data for cluster replication.
2) Added hooks to ManagementObject and ObjectId to prepare for QMFv2 object
naming.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@906038 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/include')
| -rw-r--r-- | cpp/include/qpid/management/ManagementObject.h | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/cpp/include/qpid/management/ManagementObject.h b/cpp/include/qpid/management/ManagementObject.h index d0a443d6cb..c4921269ba 100644 --- a/cpp/include/qpid/management/ManagementObject.h +++ b/cpp/include/qpid/management/ManagementObject.h @@ -51,6 +51,7 @@ protected: const AgentAttachment* agent; uint64_t first; uint64_t second; + std::string v2Key; void fromString(const std::string&); public: QPID_COMMON_EXTERN ObjectId() : agent(0), first(0), second(0) {} @@ -63,6 +64,8 @@ public: QPID_COMMON_EXTERN bool operator<(const ObjectId &other) const; QPID_COMMON_EXTERN void encode(framing::Buffer& buffer); QPID_COMMON_EXTERN void decode(framing::Buffer& buffer); + QPID_COMMON_EXTERN void setV2Key(const std::string& key) { v2Key = key; } + QPID_COMMON_EXTERN const std::string& getV2Key() const { return v2Key; } friend QPID_COMMON_EXTERN std::ostream& operator<<(std::ostream&, const ObjectId&); }; @@ -128,6 +131,7 @@ protected: QPID_COMMON_EXTERN int getThreadIndex(); QPID_COMMON_EXTERN void writeTimestamps(qpid::framing::Buffer& buf); + QPID_COMMON_EXTERN void readTimestamps(qpid::framing::Buffer& buf); public: QPID_COMMON_EXTERN static int maxThreads; @@ -141,12 +145,14 @@ protected: virtual ~ManagementObject() {} virtual writeSchemaCall_t getWriteSchemaCall() = 0; + virtual void readProperties(qpid::framing::Buffer& buf) = 0; virtual void writeProperties(qpid::framing::Buffer& buf) = 0; virtual void writeStatistics(qpid::framing::Buffer& buf, bool skipHeaders = false) = 0; virtual void doMethod(std::string& methodName, qpid::framing::Buffer& inBuf, qpid::framing::Buffer& outBuf) = 0; + virtual std::string getKey() const = 0; QPID_COMMON_EXTERN virtual void setReference(ObjectId objectId); virtual std::string& getClassName() const = 0; |