summaryrefslogtreecommitdiffstats
path: root/messagebus
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2017-09-26 23:22:00 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2017-09-26 23:22:00 +0200
commitdd8ec1f9da0b8323d5d726cad8b8df532883fcdd (patch)
treec176f7ccb2c0d71d491f12b5f4b20da57bb44194 /messagebus
parent0cd1c8e4cd02a51e9f5fa3118965644ca6f1f361 (diff)
Need to wait until first message has arrived since there are no ordering guarantees.
Diffstat (limited to 'messagebus')
-rw-r--r--messagebus/src/tests/throttling/throttling.cpp1
1 files changed, 1 insertions, 0 deletions
diff --git a/messagebus/src/tests/throttling/throttling.cpp b/messagebus/src/tests/throttling/throttling.cpp
index 279f31201c4..5d3525e8ba6 100644
--- a/messagebus/src/tests/throttling/throttling.cpp
+++ b/messagebus/src/tests/throttling/throttling.cpp
@@ -197,6 +197,7 @@ Test::testMaxPendingSize()
EXPECT_EQUAL(2u, SimpleMessage("12").getApproxSize());
EXPECT_TRUE(ss->send(Message::UP(new SimpleMessage("1")), "dst").isAccepted());
+ EXPECT_TRUE(waitQueueSize(dstQ, 1));
EXPECT_TRUE(ss->send(Message::UP(new SimpleMessage("12")), "dst").isAccepted());
EXPECT_TRUE(!ss->send(Message::UP(new SimpleMessage("1")), "dst").isAccepted());