diff options
Diffstat (limited to 'messagebus_test/src/tests/error/JavaClient.java')
-rw-r--r-- | messagebus_test/src/tests/error/JavaClient.java | 65 |
1 files changed, 0 insertions, 65 deletions
diff --git a/messagebus_test/src/tests/error/JavaClient.java b/messagebus_test/src/tests/error/JavaClient.java deleted file mode 100644 index e263b3597da..00000000000 --- a/messagebus_test/src/tests/error/JavaClient.java +++ /dev/null @@ -1,65 +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 com.yahoo.messagebus.network.rpc.test.*; -import java.util.Arrays; -import java.util.logging.*; - -public class JavaClient { - - private static Logger log = Logger.getLogger(JavaClient.class.getName()); - - 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"); - - Receptor src = new Receptor(); - Message msg = null; - Reply reply = null; - - SourceSession session = mb.getMessageBus().createSourceSession(src, new SourceSessionParams().setTimeout(300)); - for (int i = 0; i < 10; i++) { - msg = new SimpleMessage("test"); - msg.getTrace().setLevel(9); - session.send(msg, "test"); - reply = src.getReply(60); - if (reply == null) { - System.err.println("JAVA-CLIENT: no reply"); - } else { - System.err.println("JAVA-CLIENT:\n" + reply.getTrace()); - if (reply.getNumErrors() == 2) { - break; - } - } - Thread.sleep(1000); - } - if (reply == null) { - System.err.println("JAVA-CLIENT: no reply"); - System.exit(1); - } - if (reply.getNumErrors() != 2 || - reply.getError(0).getCode() != ErrorCode.APP_FATAL_ERROR + 1 || - reply.getError(1).getCode() != ErrorCode.APP_FATAL_ERROR + 2 || - !reply.getError(0).getMessage().equals("ERR 1") || - !reply.getError(1).getMessage().equals("ERR 2")) - { - System.err.printf("JAVA-CLIENT: wrong errors\n"); - System.exit(1); - } - session.destroy(); - mb.destroy(); - } catch (Exception e) { - log.log(Level.SEVERE, "JAVA-CLIENT: Failed", e); - System.exit(1); - } - } -} |