1 files changed, 47 insertions, 0 deletions
diff --git a/messagebus_test/src/tests/error/JavaServer.java b/messagebus_test/src/tests/error/JavaServer.java
new file mode 100644
index 00000000000..b5321f41fc3
--- /dev/null
+++ b/messagebus_test/src/tests/error/JavaServer.java
@@ -0,0 +1,47 @@
+// Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
+import com.yahoo.messagebus.*;
+import com.yahoo.messagebus.test.*;
+import com.yahoo.config.*;
+import com.yahoo.messagebus.routing.*;
+import com.yahoo.messagebus.network.*;
+import com.yahoo.messagebus.network.rpc.*;
+import java.util.Arrays;
+import java.util.logging.*;
+
+public class JavaServer implements MessageHandler {
+
+    private static Logger log = Logger.getLogger(JavaServer.class.getName());
+
+    private DestinationSession session;
+
+    public JavaServer(RPCMessageBus mb) {
+        session = mb.getMessageBus().createDestinationSession("session", true, this);
+    }
+
+    public void handleMessage(Message msg) {
+        Reply reply = new EmptyReply();
+        msg.swapState(reply);
+        reply.addError(new com.yahoo.messagebus.Error(ErrorCode.APP_FATAL_ERROR + 1, "ERR 1"));
+        reply.addError(new com.yahoo.messagebus.Error(ErrorCode.APP_FATAL_ERROR + 2, "ERR 2"));
+        session.reply(reply);
+    }
+
+    public static void main(String[] args) {
+        try {
+	    RPCMessageBus mb = new RPCMessageBus(
+		Arrays.asList((Protocol)new SimpleProtocol()),
+                new RPCNetworkParams()
+                .setIdentity(new Identity("server/java"))
+		.setSlobrokConfigId("file:slobrok.cfg"),
+		"file:routing.cfg");
+            JavaServer server = new JavaServer(mb);
+            System.out.println("java server started");
+            while (true) {
+                Thread.sleep(1000);
+            }
+        } catch (Exception e) {
+            log.log(Level.SEVERE, "JAVA-SERVER: Failed", e);
+            System.exit(1);
+        }
+    }
+}