From 48417321a4e7ac68950e010a2514ce95a9b0aa42 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Thu, 4 Feb 2010 08:38:24 +0000 Subject: Correct periodic flush logic in MessageReplayTracker git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@906399 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/client/MessageReplayTracker.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'cpp/src') diff --git a/cpp/src/qpid/client/MessageReplayTracker.cpp b/cpp/src/qpid/client/MessageReplayTracker.cpp index 079fb1167a..3afaae74e8 100644 --- a/cpp/src/qpid/client/MessageReplayTracker.cpp +++ b/cpp/src/qpid/client/MessageReplayTracker.cpp @@ -30,7 +30,7 @@ void MessageReplayTracker::send(const Message& message, const std::string& desti { 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(); } -- cgit v1.2.1