diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2016-09-14 00:13:11 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2016-09-14 00:13:11 +0200 |
commit | 0836f0bf337ee23c5e66f420cfa54d49e4a2104e (patch) | |
tree | 403c361cd30043cc3de04483489cfa8e25fe0ff3 /messagebus_test/src/tests/error/JavaServer.java | |
parent | 4537f2d1e36f41e74f348258aecf448b77ef1799 (diff) |
Revert "Aressem/move messagebus test tests to separate module"
Diffstat (limited to 'messagebus_test/src/tests/error/JavaServer.java')
-rw-r--r-- | messagebus_test/src/tests/error/JavaServer.java | 47 |
1 files changed, 0 insertions, 47 deletions
diff --git a/messagebus_test/src/tests/error/JavaServer.java b/messagebus_test/src/tests/error/JavaServer.java deleted file mode 100644 index b5321f41fc3..00000000000 --- a/messagebus_test/src/tests/error/JavaServer.java +++ /dev/null @@ -1,47 +0,0 @@ -// 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); - } - } -} |