You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2010/02/04 09:38:24 UTC
svn commit: r906399 -
/qpid/trunk/qpid/cpp/src/qpid/client/MessageReplayTracker.cpp
Author: gsim
Date: Thu Feb 4 08:38:24 2010
New Revision: 906399
URL: http://svn.apache.org/viewvc?rev=906399&view=rev
Log:
Correct periodic flush logic in MessageReplayTracker
Modified:
qpid/trunk/qpid/cpp/src/qpid/client/MessageReplayTracker.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/client/MessageReplayTracker.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/client/MessageReplayTracker.cpp?rev=906399&r1=906398&r2=906399&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/client/MessageReplayTracker.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/client/MessageReplayTracker.cpp Thu Feb 4 08:38:24 2010
@@ -30,7 +30,7 @@
{
buffer.push_back(ReplayRecord(message, destination));
buffer.back().send(*this);
- if (flushInterval && ++count >= flushInterval) {
+ if (flushInterval && (++count % flushInterval == 0)) {
checkCompletion();
if (!buffer.empty()) session.flush();
}
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org