diff options
Diffstat (limited to 'javae/demo/IceE/jdk/hello/Client.java')
-rw-r--r-- | javae/demo/IceE/jdk/hello/Client.java | 198 |
1 files changed, 0 insertions, 198 deletions
diff --git a/javae/demo/IceE/jdk/hello/Client.java b/javae/demo/IceE/jdk/hello/Client.java deleted file mode 100644 index f532a4e88a9..00000000000 --- a/javae/demo/IceE/jdk/hello/Client.java +++ /dev/null @@ -1,198 +0,0 @@ -// ********************************************************************** -// -// Copyright (c) 2003-2007 ZeroC, Inc. All rights reserved. -// -// This copy of Ice-E is licensed to you under the terms described in the -// ICEE_LICENSE file included in this distribution. -// -// ********************************************************************** - -import Demo.*; - -public class Client -{ - private static void - menu() - { - System.out.println( - "usage:\n" + - "t: send greeting as twoway\n" + - "o: send greeting as oneway\n" + - "O: send greeting as batch oneway\n" + - "f: flush all batch requests\n" + - "T: set a timeout\n" + - "P: set a server delay\n" + - "s: shutdown server\n" + - "x: exit\n" + - "?: help\n"); - } - - private static int - run(String[] args, Ice.Communicator communicator) - { - Ice.Properties properties = communicator.getProperties(); - final String proxyProperty = "Hello.Proxy"; - String proxy = properties.getProperty(proxyProperty); - if(proxy.length() == 0) - { - System.err.println("property `" + proxyProperty + "' not set"); - return 1; - } - - Ice.ObjectPrx base = communicator.stringToProxy(proxy); - HelloPrx twoway = HelloPrxHelper.checkedCast(base.ice_twoway().ice_timeout(-1)); - if(twoway == null) - { - System.err.println("invalid proxy"); - return 1; - } - HelloPrx oneway = HelloPrxHelper.uncheckedCast(twoway.ice_oneway()); - HelloPrx batchOneway = HelloPrxHelper.uncheckedCast(twoway.ice_batchOneway()); - - int timeout = -1; - int delay = 0; - - menu(); - - java.io.BufferedReader in = new java.io.BufferedReader(new java.io.InputStreamReader(System.in)); - - String line = null; - do - { - try - { - System.out.print("==> "); - System.out.flush(); - line = in.readLine(); - if(line == null) - { - break; - } - if(line.equals("t")) - { - twoway.sayHello(delay); - } - else if(line.equals("o")) - { - oneway.sayHello(delay); - } - else if(line.equals("O")) - { - batchOneway.sayHello(delay); - } - else if(line.equals("f")) - { - communicator.flushBatchRequests(); - } - else if(line.equals("T")) - { - if(timeout == -1) - { - timeout = 2000; - } - else - { - timeout = -1; - } - - twoway = HelloPrxHelper.uncheckedCast(twoway.ice_timeout(timeout)); - oneway = HelloPrxHelper.uncheckedCast(oneway.ice_timeout(timeout)); - batchOneway = HelloPrxHelper.uncheckedCast(batchOneway.ice_timeout(timeout)); - - if(timeout == -1) - { - System.out.println("timeout is now switched off"); - } - else - { - System.out.println("timeout is now set to 2000ms"); - } - } - else if(line.equals("P")) - { - if(delay == 0) - { - delay = 2500; - } - else - { - delay = 0; - } - - if(delay == 0) - { - System.out.println("server delay is now deactivated"); - } - else - { - System.out.println("server delay is now set to 2500ms"); - } - } - else if(line.equals("s")) - { - twoway.shutdown(); - } - else if(line.equals("x")) - { - // Nothing to do - } - else if(line.equals("?")) - { - menu(); - } - else - { - System.out.println("unknown command `" + line + "'"); - menu(); - } - } - catch(java.io.IOException ex) - { - ex.printStackTrace(); - } - catch(Ice.LocalException ex) - { - ex.printStackTrace(); - } - } - while(!line.equals("x")); - - return 0; - } - - public static void - main(String[] args) - { - int status = 0; - Ice.Communicator communicator = null; - - try - { - Ice.InitializationData initData = new Ice.InitializationData(); - initData.properties = Ice.Util.createProperties(); - initData.properties.load("config"); - communicator = Ice.Util.initialize(args, initData); - status = run(args, communicator); - } - catch(Ice.LocalException ex) - { - ex.printStackTrace(); - status = 1; - } - - if(communicator != null) - { - try - { - communicator.destroy(); - } - catch(Ice.LocalException ex) - { - ex.printStackTrace(); - status = 1; - } - } - - System.exit(status); - } -} |