diff options
author | Henning Baldersheim <balder@oath.com> | 2018-10-04 22:05:19 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@oath.com> | 2018-10-04 22:05:19 +0200 |
commit | 0bdd3c5fa4326ed4106b9aee0585d57c7193bd97 (patch) | |
tree | 2b519cf259eb30ab28d85fc560a589457f54ed17 /messagebus/src/tests/bucketsequence/bucketsequence.cpp | |
parent | 3f2b1a9230fbab12f2e8b5afcf1e0ad72f3d872a (diff) |
Remove the costly and unnecessary setSlobrokId interface.
Diffstat (limited to 'messagebus/src/tests/bucketsequence/bucketsequence.cpp')
-rw-r--r-- | messagebus/src/tests/bucketsequence/bucketsequence.cpp | 11 |
1 files changed, 5 insertions, 6 deletions
diff --git a/messagebus/src/tests/bucketsequence/bucketsequence.cpp b/messagebus/src/tests/bucketsequence/bucketsequence.cpp index d98acc4f191..57d1f99e5c3 100644 --- a/messagebus/src/tests/bucketsequence/bucketsequence.cpp +++ b/messagebus/src/tests/bucketsequence/bucketsequence.cpp @@ -26,19 +26,18 @@ Test::Main() Slobrok slobrok; TestServer server(MessageBusParams() - .addProtocol(IProtocol::SP(new SimpleProtocol())) - .setRetryPolicy(IRetryPolicy::SP(new RetryTransientErrorsPolicy())), - RPCNetworkParams() - .setSlobrokConfig(slobrok.config())); + .addProtocol(std::make_shared<SimpleProtocol>()) + .setRetryPolicy(std::make_shared<RetryTransientErrorsPolicy>()), + RPCNetworkParams(slobrok.config())); Receptor receptor; SourceSession::UP session = server.mb.createSourceSession( SourceSessionParams() .setReplyHandler(receptor)); - Message::UP msg(new MyMessage()); + auto msg = std::make_unique<MyMessage>(); msg->setRoute(Route::parse("foo")); ASSERT_TRUE(session->send(std::move(msg)).isAccepted()); Reply::UP reply = receptor.getReply(); - ASSERT_TRUE(reply.get() != NULL); + ASSERT_TRUE(reply.get() != nullptr); EXPECT_EQUAL(1u, reply->getNumErrors()); EXPECT_EQUAL((uint32_t)ErrorCode::SEQUENCE_ERROR, reply->getError(0).getCode()); |