From e8f99e5859125f5a1a9ab89116946b76e822cb30 Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Mon, 20 Oct 2008 19:37:06 +0000 Subject: cluster: DumpClient replicates session MessageBuilder. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@706381 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/broker/IncompleteMessageList.cpp | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) (limited to 'cpp/src/qpid/broker/IncompleteMessageList.cpp') diff --git a/cpp/src/qpid/broker/IncompleteMessageList.cpp b/cpp/src/qpid/broker/IncompleteMessageList.cpp index dd7bbfc067..edb3721a40 100644 --- a/cpp/src/qpid/broker/IncompleteMessageList.cpp +++ b/cpp/src/qpid/broker/IncompleteMessageList.cpp @@ -30,7 +30,7 @@ void IncompleteMessageList::add(boost::intrusive_ptr msg) incomplete.push_back(msg); } -void IncompleteMessageList::process(CompletionListener l, bool sync) +void IncompleteMessageList::process(const CompletionListener& l, bool sync) { while (!incomplete.empty()) { boost::intrusive_ptr& msg = incomplete.front(); @@ -48,4 +48,8 @@ void IncompleteMessageList::process(CompletionListener l, bool sync) } } +void IncompleteMessageList::each(const CompletionListener& l) { + std::for_each(incomplete.begin(), incomplete.end(), l); +} + }} -- cgit v1.2.1