From 067a67c5c422c9bec63210ccf58f30241b521cea Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Fri, 27 Feb 2009 18:11:47 +0000 Subject: Fix test to account for failure after last message has been delivered, but before the session and connection are closed. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748624 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/tests/resuming_receiver.cpp | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) (limited to 'cpp/src') diff --git a/cpp/src/tests/resuming_receiver.cpp b/cpp/src/tests/resuming_receiver.cpp index f49a115e1e..da7c5f32ff 100644 --- a/cpp/src/tests/resuming_receiver.cpp +++ b/cpp/src/tests/resuming_receiver.cpp @@ -53,6 +53,7 @@ class Listener : public MessageListener, bool gaps; uint reportFrequency; int verbosity; + bool done; }; @@ -62,7 +63,8 @@ Listener::Listener(int freq, int verbosity) lastSn(0), gaps(false), reportFrequency(freq), - verbosity(verbosity) + verbosity(verbosity), + done(false) {} @@ -116,9 +118,11 @@ void Listener::execute(AsyncSession& session, bool isRetry) if (isRetry) { // std::cout << "Resuming from " << count << std::endl; } - SubscriptionManager subs(session); - subscription = subs.subscribe(*this, "message_queue"); - subs.run(); + if (!done) { + SubscriptionManager subs(session); + subscription = subs.subscribe(*this, "message_queue"); + subs.run(); + } } void Listener::editUrlList(std::vector& urls) -- cgit v1.2.1