aboutsummaryrefslogtreecommitdiffstats
path: root/messagebus/src/tests/bucketsequence/bucketsequence.cpp
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@oath.com>2018-10-04 22:05:19 +0200
committerHenning Baldersheim <balder@oath.com>2018-10-04 22:05:19 +0200
commit0bdd3c5fa4326ed4106b9aee0585d57c7193bd97 (patch)
tree2b519cf259eb30ab28d85fc560a589457f54ed17 /messagebus/src/tests/bucketsequence/bucketsequence.cpp
parent3f2b1a9230fbab12f2e8b5afcf1e0ad72f3d872a (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.cpp11
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());