diff options
| author | Gordon Sim <gsim@apache.org> | 2010-02-04 08:38:24 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2010-02-04 08:38:24 +0000 |
| commit | 48417321a4e7ac68950e010a2514ce95a9b0aa42 (patch) | |
| tree | 59513fc30d266dba7b075ad40d4e0df2597592b5 /cpp | |
| parent | 02422c257fed351d92bae1cd98f8e6cb21d2d325 (diff) | |
| download | qpid-python-48417321a4e7ac68950e010a2514ce95a9b0aa42.tar.gz | |
Correct periodic flush logic in MessageReplayTracker
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@906399 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp')
| -rw-r--r-- | cpp/src/qpid/client/MessageReplayTracker.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
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(); } |