diff options
Diffstat (limited to 'messagebus_test/src/tests/speed')
| -rw-r--r-- | messagebus_test/src/tests/speed/cpp-client.cpp | 4 | ||||
| -rw-r--r-- | messagebus_test/src/tests/speed/cpp-server.cpp | 8 |
2 files changed, 6 insertions, 6 deletions
diff --git a/messagebus_test/src/tests/speed/cpp-client.cpp b/messagebus_test/src/tests/speed/cpp-client.cpp index 385f983b7cb..d8ba5d85169 100644 --- a/messagebus_test/src/tests/speed/cpp-client.cpp +++ b/messagebus_test/src/tests/speed/cpp-client.cpp @@ -96,8 +96,8 @@ App::Main() auto retryPolicy = std::make_shared<RetryTransientErrorsPolicy>(); retryPolicy->setBaseDelay(0.1); RPCMessageBus mb(MessageBusParams().setRetryPolicy(retryPolicy).addProtocol(std::make_shared<SimpleProtocol>()), - RPCNetworkParams("file:slobrok.cfg").setIdentity(Identity("server/cpp")), - "file:routing.cfg"); + RPCNetworkParams(config::ConfigUri("file:slobrok.cfg")).setIdentity(Identity("server/cpp")), + config::ConfigUri("file:routing.cfg")); Client client(mb.getMessageBus(), SourceSessionParams().setTimeout(30s)); // let the system 'warm up' diff --git a/messagebus_test/src/tests/speed/cpp-server.cpp b/messagebus_test/src/tests/speed/cpp-server.cpp index 8d6fa65f530..20a72596182 100644 --- a/messagebus_test/src/tests/speed/cpp-server.cpp +++ b/messagebus_test/src/tests/speed/cpp-server.cpp @@ -39,11 +39,11 @@ Server::handleMessage(Message::UP msg) { && (msg->getType() == SimpleProtocol::MESSAGE) && (static_cast<SimpleMessage&>(*msg).getValue() == "message")) { - Reply::UP reply(new SimpleReply("OK")); + auto reply = std::make_unique<SimpleReply>("OK"); msg->swapState(*reply); _session->reply(std::move(reply)); } else { - Reply::UP reply(new SimpleReply("FAIL")); + auto reply = std::make_unique<SimpleReply>("FAIL"); msg->swapState(*reply); _session->reply(std::move(reply)); } @@ -59,9 +59,9 @@ int App::Main() { RPCMessageBus mb(ProtocolSet().add(std::make_shared<SimpleProtocol>()), - RPCNetworkParams("file:slobrok.cfg") + RPCNetworkParams(config::ConfigUri("file:slobrok.cfg")) .setIdentity(Identity("server/cpp")), - "file:routing.cfg"); + config::ConfigUri("file:routing.cfg")); Server server(mb.getMessageBus()); while (true) { std::this_thread::sleep_for(1s); |