Publish

1 files changed, 44 insertions, 0 deletions

diff --git a/messagebus/src/tests/rpcserviceaddress/rpcserviceaddress.cpp b/messagebus/src/tests/rpcserviceaddress/rpcserviceaddress.cpp
new file mode 100644
index 00000000000..d5a002adf89
--- /dev/null
+++ b/messagebus/src/tests/rpcserviceaddress/rpcserviceaddress.cpp
@@ -0,0 +1,44 @@
+// 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("rpcserviceaddress_test");
+#include <vespa/vespalib/testkit/testapp.h>
+#include <vespa/messagebus/network/rpcserviceaddress.h>
+
+using namespace mbus;
+
+TEST_SETUP(Test);
+
+int
+Test::Main()
+{
+    TEST_INIT("rpcserviceaddress_test");
+    {
+        EXPECT_TRUE(RPCServiceAddress("", "bar").isMalformed());
+        EXPECT_TRUE(RPCServiceAddress("foo", "bar").isMalformed());
+        EXPECT_TRUE(RPCServiceAddress("foo/", "bar").isMalformed());
+        EXPECT_TRUE(RPCServiceAddress("/foo", "bar").isMalformed());
+    }
+    {
+        RPCServiceAddress addr("foo/bar/baz", "tcp/foo.com:42");
+        EXPECT_TRUE(!addr.isMalformed());
+        EXPECT_TRUE(addr.getServiceName() == "foo/bar/baz");
+        EXPECT_TRUE(addr.getConnectionSpec() == "tcp/foo.com:42");
+        EXPECT_TRUE(addr.getSessionName() == "baz");
+    }
+    {
+        RPCServiceAddress addr("foo/bar", "tcp/foo.com:42");
+        EXPECT_TRUE(!addr.isMalformed());
+        EXPECT_TRUE(addr.getServiceName() == "foo/bar");
+        EXPECT_TRUE(addr.getConnectionSpec() == "tcp/foo.com:42");
+        EXPECT_TRUE(addr.getSessionName() == "bar");
+    }
+    {
+        RPCServiceAddress addr("", "tcp/foo.com:42");
+        EXPECT_TRUE(addr.isMalformed());
+        EXPECT_TRUE(addr.getServiceName() == "");
+        EXPECT_TRUE(addr.getConnectionSpec() == "tcp/foo.com:42");
+        EXPECT_TRUE(addr.getSessionName() == "");
+    }
+    TEST_DONE();
+}