1 files changed, 77 insertions, 0 deletions
diff --git a/messagebus_test/src/tests/speed/cpp-server.cpp b/messagebus_test/src/tests/speed/cpp-server.cpp
new file mode 100644
index 00000000000..c2cd9bf262a
--- /dev/null
+++ b/messagebus_test/src/tests/speed/cpp-server.cpp
@@ -0,0 +1,77 @@
+// Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
+#include <vespa/fastos/fastos.h>
+#include <vespa/log/log.h>
+LOG_SETUP("cpp-server");
+#include <vespa/messagebus/messagebus.h>
+#include <vespa/messagebus/destinationsession.h>
+#include <vespa/messagebus/testlib/simplemessage.h>
+#include <vespa/messagebus/testlib/simplereply.h>
+#include <vespa/messagebus/testlib/simpleprotocol.h>
+#include <vespa/messagebus/rpcmessagebus.h>
+#include <vespa/messagebus/iprotocol.h>
+#include <vespa/messagebus/protocolset.h>
+
+using namespace mbus;
+
+class Server : public IMessageHandler
+{
+private:
+    DestinationSession::UP _session;
+public:
+    Server(MessageBus &bus);
+    ~Server();
+    void handleMessage(Message::UP msg);
+};
+
+Server::Server(MessageBus &bus)
+    : _session(bus.createDestinationSession("session", true, *this))
+{
+    fprintf(stderr, "cpp server started\n");
+}
+
+Server::~Server()
+{
+    _session.reset();
+}
+
+void
+Server::handleMessage(Message::UP msg) {
+    if ((msg->getProtocol() == SimpleProtocol::NAME)
+        && (msg->getType() == SimpleProtocol::MESSAGE)
+        && (static_cast<SimpleMessage&>(*msg).getValue() == "message"))
+    {
+        Reply::UP reply(new SimpleReply("OK"));
+        msg->swapState(*reply);
+        _session->reply(std::move(reply));
+    } else {
+        Reply::UP reply(new SimpleReply("FAIL"));
+        msg->swapState(*reply);
+        _session->reply(std::move(reply));
+    }
+}
+
+class App : public FastOS_Application
+{
+public:
+    int Main();
+};
+
+int
+App::Main()
+{
+    RPCMessageBus mb(ProtocolSet().add(IProtocol::SP(new SimpleProtocol())),
+                     RPCNetworkParams()
+                     .setIdentity(Identity("server/cpp"))
+                     .setSlobrokConfig("file:slobrok.cfg"),
+                     "file:routing.cfg");
+    Server server(mb.getMessageBus());
+    while (true) {
+        FastOS_Thread::Sleep(1000);
+    }
+    return 0;
+}
+
+int main(int argc, char **argv) {
+    App app;
+    return app.Entry(argc, argv);
+}