summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/amqp_0_10
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2008-06-04 17:24:10 +0000
committerAlan Conway <aconway@apache.org>2008-06-04 17:24:10 +0000
commit8654fb2db74eacff8ec943d192f80ef1fd512f6e (patch)
treeeb07d031edc4a1672a2adee60a0885f665bd9d16 /cpp/src/qpid/amqp_0_10
parent656a4f3d5fcea275f954e3d1c9eaa5087a2e7005 (diff)
downloadqpid-python-8654fb2db74eacff8ec943d192f80ef1fd512f6e.tar.gz
Request a timely reqply to session.completed based on configured flush interval.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@663318 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/amqp_0_10')
-rw-r--r--cpp/src/qpid/amqp_0_10/SessionHandler.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/cpp/src/qpid/amqp_0_10/SessionHandler.cpp b/cpp/src/qpid/amqp_0_10/SessionHandler.cpp
index 53f847a3cf..fa05cee1b3 100644
--- a/cpp/src/qpid/amqp_0_10/SessionHandler.cpp
+++ b/cpp/src/qpid/amqp_0_10/SessionHandler.cpp
@@ -243,7 +243,7 @@ void SessionHandler::sendDetach()
void SessionHandler::sendCompletion() {
checkAttached();
const SequenceSet& c = getState()->receiverGetUnknownComplete();
- peer.completed(c, c.span() > 1000);
+ peer.completed(c, getState()->receiverNeedKnownCompleted());
}
void SessionHandler::sendAttach(bool force) {