summaryrefslogtreecommitdiff
path: root/qpid/cpp/src
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2009-10-27 17:55:52 +0000
committerAlan Conway <aconway@apache.org>2009-10-27 17:55:52 +0000
commitc61fee9b3c7486d6c35dd92f52dfb96a8de79fe6 (patch)
tree7b9dff61c74b65ca23e22b2479f5449791a08cce /qpid/cpp/src
parenta77294d7570a35513fcee77f2500ff3f023fc5d8 (diff)
downloadqpid-python-c61fee9b3c7486d6c35dd92f52dfb96a8de79fe6.tar.gz
Added missing resetDequeueCompleteCallback calls to ~IncompleteMessageList.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@830269 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src')
-rw-r--r--qpid/cpp/src/qpid/broker/IncompleteMessageList.cpp5
1 files changed, 4 insertions, 1 deletions
diff --git a/qpid/cpp/src/qpid/broker/IncompleteMessageList.cpp b/qpid/cpp/src/qpid/broker/IncompleteMessageList.cpp
index 4065d92467..02265ab85c 100644
--- a/qpid/cpp/src/qpid/broker/IncompleteMessageList.cpp
+++ b/qpid/cpp/src/qpid/broker/IncompleteMessageList.cpp
@@ -31,7 +31,10 @@ IncompleteMessageList::IncompleteMessageList() :
IncompleteMessageList::~IncompleteMessageList()
{
sys::Mutex::ScopedLock l(lock);
- std::for_each(incomplete.begin(), incomplete.end(), boost::bind(&Message::resetEnqueueCompleteCallback, _1));
+ for (Messages::iterator i = incomplete.begin(); i != incomplete.end(); ++i) {
+ (*i)->resetEnqueueCompleteCallback();
+ (*i)->resetDequeueCompleteCallback();
+ }
}
void IncompleteMessageList::add(boost::intrusive_ptr<Message> msg)