Fix intermittent test error: cluster_test.cpp(1108): error in "testRelease": check browse(c3, "q", 5) == expected failed [ != m_1 m_2 m_3 m_4 m_5 ]

This was a test issue, not a broker issue. What seems to have been happening:
 - start broker b0 & send messages.
 - fork broker b1
 - line 1103 (lqSub.release(...)); executes against b0 _before_ b1 connects for update         lqSub.release(lqSub.getUnaccepted());
 - line 1108 browse() executes during the update.
 - update takes > 0.5 secs for some reason, browse times out.

The fix is a synchronous flush in browse() which will wait for the broker to be responsive before trying to get the messages.


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

1 files changed, 1 insertions, 0 deletions

diff --git a/qpid/cpp/src/tests/cluster_test.cpp b/qpid/cpp/src/tests/cluster_test.cpp
index 33f23aa5b3..bb1c014b99 100644
--- a/qpid/cpp/src/tests/cluster_test.cpp
+++ b/qpid/cpp/src/tests/cluster_test.cpp
@@ -157,6 +157,7 @@ vector<string> browse(Client& c, const string& q, int n) {
     );
     LocalQueue lq;
     c.subs.subscribe(lq, q, browseSettings);
+    c.session.messageFlush(q);
     vector<string> result;
     for (int i = 0; i < n; ++i) {
         Message m;