aboutsummaryrefslogtreecommitdiffstats
path: root/messagebus/src/tests/bucketsequence/bucketsequence.cpp
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2020-07-08 21:54:01 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2020-07-08 21:54:01 +0000
commitf347ac4acf9f00cb1800bbcf579dbc66431a57e6 (patch)
treeb0ddb06976ab7a27ec04bf3962481a64e1e1181d /messagebus/src/tests/bucketsequence/bucketsequence.cpp
parente0fc80d4c7a9ba5ef62d8e920e4f1e7576685976 (diff)
Remove non-semantic changes prior to using a sequenced threadpool in mbus.
Diffstat (limited to 'messagebus/src/tests/bucketsequence/bucketsequence.cpp')
-rw-r--r--messagebus/src/tests/bucketsequence/bucketsequence.cpp15
1 files changed, 5 insertions, 10 deletions
diff --git a/messagebus/src/tests/bucketsequence/bucketsequence.cpp b/messagebus/src/tests/bucketsequence/bucketsequence.cpp
index 57d1f99e5c3..671f50efc03 100644
--- a/messagebus/src/tests/bucketsequence/bucketsequence.cpp
+++ b/messagebus/src/tests/bucketsequence/bucketsequence.cpp
@@ -11,19 +11,13 @@
using namespace mbus;
-TEST_SETUP(Test);
-
class MyMessage : public SimpleMessage {
public:
MyMessage() : SimpleMessage("foo") { }
- bool hasBucketSequence() override { return true; }
+ bool hasBucketSequence() const override { return true; }
};
-int
-Test::Main()
-{
- TEST_INIT("bucketsequence_test");
-
+TEST("bucketsequence_test") {
Slobrok slobrok;
TestServer server(MessageBusParams()
.addProtocol(std::make_shared<SimpleProtocol>())
@@ -37,9 +31,10 @@ Test::Main()
msg->setRoute(Route::parse("foo"));
ASSERT_TRUE(session->send(std::move(msg)).isAccepted());
Reply::UP reply = receptor.getReply();
- ASSERT_TRUE(reply.get() != nullptr);
+ ASSERT_TRUE(reply);
EXPECT_EQUAL(1u, reply->getNumErrors());
EXPECT_EQUAL((uint32_t)ErrorCode::SEQUENCE_ERROR, reply->getError(0).getCode());
- TEST_DONE();
}
+
+TEST_MAIN() { TEST_RUN_ALL(); }