diff options
Diffstat (limited to 'cpp')
| -rw-r--r-- | cpp/src/qpid/broker/MessageGroupManager.cpp | 15 | ||||
| -rw-r--r-- | cpp/src/qpid/broker/Messages.h | 7 |
2 files changed, 1 insertions, 21 deletions
diff --git a/cpp/src/qpid/broker/MessageGroupManager.cpp b/cpp/src/qpid/broker/MessageGroupManager.cpp index 47e40a4794..0c70b6d448 100644 --- a/cpp/src/qpid/broker/MessageGroupManager.cpp +++ b/cpp/src/qpid/broker/MessageGroupManager.cpp @@ -302,19 +302,6 @@ void MessageGroupManager::setDefaults(const std::string& groupId) // static defaultGroupId = groupId; } -/** Cluster replication: - - state map format: - - { "group-state": [ {"name": <group-name>, - "owner": <consumer-name>-or-empty, - "acquired-ct": <acquired count>, - "positions": [Seqnumbers, ... ]}, - {...} - ] - } -*/ - namespace { const std::string GROUP_NAME("name"); const std::string GROUP_OWNER("owner"); @@ -368,7 +355,7 @@ void MessageGroupManager::setState(const qpid::framing::FieldTable& state) bool ok = state.getArray(GROUP_STATE, groupState); if (!ok) { QPID_LOG(error, "Unable to find message group state information for queue \"" << - qName << "\": cluster inconsistency error!"); + qName << "\""); return; } diff --git a/cpp/src/qpid/broker/Messages.h b/cpp/src/qpid/broker/Messages.h index a94ac7e0bf..cd846a4973 100644 --- a/cpp/src/qpid/broker/Messages.h +++ b/cpp/src/qpid/broker/Messages.h @@ -91,13 +91,6 @@ class Messages virtual Message* find(const QueueCursor&) = 0; /** - * Add an already acquired message to the queue. - * Used by a cluster updatee to replicate acquired messages from the updater. - * Only need be implemented by subclasses that keep track of - * acquired messages. - */ - //virtual void updateAcquired(const QueuedMessage&) { } - /** * Apply, the functor to each message held */ virtual void foreach(Functor) = 0; |