You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2009/10/27 18:55:52 UTC
svn commit: r830269 -
/qpid/trunk/qpid/cpp/src/qpid/broker/IncompleteMessageList.cpp
Author: aconway
Date: Tue Oct 27 17:55:52 2009
New Revision: 830269
URL: http://svn.apache.org/viewvc?rev=830269&view=rev
Log:
Added missing resetDequeueCompleteCallback calls to ~IncompleteMessageList.
Modified:
qpid/trunk/qpid/cpp/src/qpid/broker/IncompleteMessageList.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/broker/IncompleteMessageList.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/IncompleteMessageList.cpp?rev=830269&r1=830268&r2=830269&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/IncompleteMessageList.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/IncompleteMessageList.cpp Tue Oct 27 17:55:52 2009
@@ -31,7 +31,10 @@
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)
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org