diff options
Diffstat (limited to 'java/demo/Glacier2/callback/CallbackClient.java')
| -rw-r--r-- | java/demo/Glacier2/callback/CallbackClient.java | 235 |
1 files changed, 0 insertions, 235 deletions
diff --git a/java/demo/Glacier2/callback/CallbackClient.java b/java/demo/Glacier2/callback/CallbackClient.java deleted file mode 100644 index 98b73d6b99e..00000000000 --- a/java/demo/Glacier2/callback/CallbackClient.java +++ /dev/null @@ -1,235 +0,0 @@ -// ********************************************************************** -// -// Copyright (c) 2003-2005 ZeroC, Inc. All rights reserved. -// -// This copy of Ice is licensed to you under the terms described in the -// ICE_LICENSE file included in this distribution. -// -// ********************************************************************** - -import Demo.*; - -class CallbackClient extends Ice.Application -{ - private static void - menu() - { - System.out.println( - "usage:\n" + - "t: send callback as twoway\n" + - "o: send callback as oneway\n" + - "O: send callback as batch oneway\n" + - "f: flush all batch requests\n" + - "v: set/reset override context field\n" + - "F: set/reset fake category\n" + - "s: shutdown server\n" + - "x: exit\n" + - "?: help\n"); - } - - public int - run(String[] args) - { - Ice.RouterPrx defaultRouter = communicator().getDefaultRouter(); - if(defaultRouter == null) - { - System.err.println("no default router set"); - return 1; - } - - Glacier2.RouterPrx router = Glacier2.RouterPrxHelper.checkedCast(defaultRouter); - if(router == null) - { - System.err.println("configured router is not a Glacier2 router"); - return 1; - } - - java.io.BufferedReader in = new java.io.BufferedReader(new java.io.InputStreamReader(System.in)); - while(true) - { - System.out.println("This demo accepts any user-id / password combination."); - - try - { - String id; - System.out.print("user id: "); - System.out.flush(); - id = in.readLine(); - - String pw; - System.out.print("password: "); - System.out.flush(); - pw = in.readLine(); - - try - { - router.createSession(id, pw); - break; - } - catch(Glacier2.PermissionDeniedException ex) - { - System.out.println("permission denied:\n" + ex.reason); - } - catch(Glacier2.CannotCreateSessionException ex) - { - System.out.println("cannot create session:\n" + ex.reason); - } - } - catch(java.io.IOException ex) - { - ex.printStackTrace(); - } - catch(Ice.LocalException ex) - { - ex.printStackTrace(); - } - } - - String category = router.getServerProxy().ice_getIdentity().category; - Ice.Identity callbackReceiverIdent = new Ice.Identity(); - callbackReceiverIdent.name = "callbackReceiver"; - callbackReceiverIdent.category = category; - Ice.Identity callbackReceiverFakeIdent = new Ice.Identity(); - callbackReceiverFakeIdent.name = "callbackReceiver"; - callbackReceiverFakeIdent.category = "fake"; - - Ice.Properties properties = communicator().getProperties(); - final String proxyProperty = "Callback.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); - CallbackPrx twoway = CallbackPrxHelper.checkedCast(base); - CallbackPrx oneway = CallbackPrxHelper.uncheckedCast(twoway.ice_oneway()); - CallbackPrx batchOneway = CallbackPrxHelper.uncheckedCast(twoway.ice_batchOneway()); - - Ice.ObjectAdapter adapter = communicator().createObjectAdapter("Callback.Client"); - adapter.add(new CallbackReceiverI(), callbackReceiverIdent); - adapter.add(new CallbackReceiverI(), callbackReceiverFakeIdent); - adapter.activate(); - - CallbackReceiverPrx twowayR = CallbackReceiverPrxHelper.uncheckedCast( - adapter.createProxy(callbackReceiverIdent)); - CallbackReceiverPrx onewayR = CallbackReceiverPrxHelper.uncheckedCast(twowayR.ice_oneway()); - - menu(); - - String line = null; - String override = null; - boolean fake = false; - do - { - try - { - System.out.print("==> "); - System.out.flush(); - line = in.readLine(); - if(line == null) - { - break; - } - if(line.equals("t")) - { - java.util.Map context = new java.util.HashMap(); - context.put("_fwd", "t"); - if(override != null) - { - context.put("_ovrd", override); - } - twoway.initiateCallback(twowayR, context); - } - else if(line.equals("o")) - { - java.util.Map context = new java.util.HashMap(); - context.put("_fwd", "o"); - if(override != null) - { - context.put("_ovrd", override); - } - oneway.initiateCallback(onewayR, context); - } - else if(line.equals("O")) - { - java.util.Map context = new java.util.HashMap(); - context.put("_fwd", "O"); - if(override != null) - { - context.put("_ovrd", override); - } - batchOneway.initiateCallback(onewayR, context); - } - else if(line.equals("f")) - { - communicator().flushBatchRequests(); - } - else if(line.equals("v")) - { - if(override == null) - { - override = "some_value"; - System.out.println("override context field is now `" + override + "'"); - } - else - { - override = null; - System.out.println("override context field is empty"); - } - } - else if(line.equals("F")) - { - fake = !fake; - - if(fake) - { - twowayR = CallbackReceiverPrxHelper.uncheckedCast( - twowayR.ice_newIdentity(callbackReceiverFakeIdent)); - onewayR = CallbackReceiverPrxHelper.uncheckedCast( - onewayR.ice_newIdentity(callbackReceiverFakeIdent)); - } - else - { - twowayR = CallbackReceiverPrxHelper.uncheckedCast( - twowayR.ice_newIdentity(callbackReceiverIdent)); - onewayR = CallbackReceiverPrxHelper.uncheckedCast( - onewayR.ice_newIdentity(callbackReceiverIdent)); - } - - System.out.println("callback receiver identity: " + - Ice.Util.identityToString(twowayR.ice_getIdentity())); - } - 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; - } -} |