diff options
Diffstat (limited to 'qpid/cpp/src/qpid/broker/Messages.h')
| -rw-r--r-- | qpid/cpp/src/qpid/broker/Messages.h | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/qpid/cpp/src/qpid/broker/Messages.h b/qpid/cpp/src/qpid/broker/Messages.h index 89f6d383ae..61e9fa110a 100644 --- a/qpid/cpp/src/qpid/broker/Messages.h +++ b/qpid/cpp/src/qpid/broker/Messages.h @@ -93,7 +93,15 @@ class Messages virtual bool push(const QueuedMessage& added, QueuedMessage& removed) = 0; /** - * Apply the functor to each message held + * 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; /** |