Correct periodic flush logic in MessageReplayTracker

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@906399 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 1 insertions, 1 deletions

diff --git a/qpid/cpp/src/qpid/client/MessageReplayTracker.cpp b/qpid/cpp/src/qpid/client/MessageReplayTracker.cpp
index 079fb1167a..3afaae74e8 100644
--- a/qpid/cpp/src/qpid/client/MessageReplayTracker.cpp
+++ b/qpid/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();
     }