diff options
Diffstat (limited to 'qpid/cpp/src/tests/cluster_test.cpp')
| -rw-r--r-- | qpid/cpp/src/tests/cluster_test.cpp | 1 |
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; |