diff options
| author | Kenneth Anthony Giusti <kgiusti@apache.org> | 2011-06-10 15:33:18 +0000 |
|---|---|---|
| committer | Kenneth Anthony Giusti <kgiusti@apache.org> | 2011-06-10 15:33:18 +0000 |
| commit | fad8c14f142d3cf8fd41f4edac6abcadfa21fc65 (patch) | |
| tree | b7fb1f95fd63475dd437742dba2219782471b166 | |
| parent | e11fb93fdbffee2e74d6c1c06d645de2b144dc4a (diff) | |
| download | qpid-python-fad8c14f142d3cf8fd41f4edac6abcadfa21fc65.tar.gz | |
QPID-3079: add sync recommended by gsim
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3079@1134345 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | qpid/cpp/src/tests/AsyncCompletion.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/qpid/cpp/src/tests/AsyncCompletion.cpp b/qpid/cpp/src/tests/AsyncCompletion.cpp index 519e9d367b..a19b3a9920 100644 --- a/qpid/cpp/src/tests/AsyncCompletion.cpp +++ b/qpid/cpp/src/tests/AsyncCompletion.cpp @@ -124,10 +124,11 @@ QPID_AUTO_TEST_CASE(testWaitTillComplete) { LocalQueue q; Subscription sub = fix.subs.subscribe(q, "q", settings); s.messageFlush(arg::destination=sub.getName()); + s.sync(); SequenceSet accepted; for (int x = 0; x < count; x++) { Message m; - BOOST_CHECK(q.get(m, TIME_SEC * 3)); + BOOST_CHECK(q.get(m, TIME_SEC)); accepted.add(m.getId()); } |