java/demo/IceBox/hello/Client.java

   1 // **********************************************************************
   2 //
   3 // Copyright (c) 2003-2011 ZeroC, Inc. All rights reserved.
   4 //
   5 // This copy of Ice is licensed to you under the terms described in the
   6 // ICE_LICENSE file included in this distribution.
   7 //
   8 // **********************************************************************
   9
  10 import Demo.*;
  11
  12 public class Client extends Ice.Application
  13 {
  14     class ShutdownHook extends Thread
  15     {
  16         public void
  17         run()
  18         {
  19             try
  20             {
  21                 communicator().destroy();
  22             }
  23             catch(Ice.LocalException ex)
  24             {
  25                 ex.printStackTrace();
  26             }
  27         }
  28     }
  29
  30     private void
  31     menu()
  32     {
  33         System.out.println(
  34             "usage:\n" +
  35             "t: send greeting as twoway\n" +
  36             "o: send greeting as oneway\n" +
  37             "O: send greeting as batch oneway\n" +
  38             "d: send greeting as datagram\n" +
  39             "D: send greeting as batch datagram\n" +
  40             "f: flush all batch requests\n" +
  41             "x: exit\n" +
  42             "?: help\n");
  43     }
  44
  45     public int
  46     run(String[] args)
  47     {
  48         if(args.length > 0)
  49         {
  50             System.err.println(appName() + ": too many arguments");
  51             return 1;
  52         }
  53
  54         //
  55         // Since this is an interactive demo we want to clear the
  56         // Application installed interrupt callback and install our
  57         // own shutdown hook.
  58         //
  59         setInterruptHook(new ShutdownHook());
  60
  61         HelloPrx twoway = HelloPrxHelper.checkedCast(
  62             communicator().propertyToProxy("Hello.Proxy").ice_twoway().ice_timeout(-1).ice_secure(false));
  63         if(twoway == null)
  64         {
  65             System.err.println("invalid object reference");
  66             return 1;
  67         }
  68         HelloPrx oneway = HelloPrxHelper.uncheckedCast(twoway.ice_oneway());
  69         HelloPrx batchOneway = HelloPrxHelper.uncheckedCast(twoway.ice_batchOneway());
  70         HelloPrx datagram = HelloPrxHelper.uncheckedCast(twoway.ice_datagram());
  71         HelloPrx batchDatagram = HelloPrxHelper.uncheckedCast(twoway.ice_batchDatagram());
  72
  73         menu();
  74
  75         java.io.BufferedReader in = new java.io.BufferedReader(new java.io.InputStreamReader(System.in));
  76
  77         String line = null;
  78         do
  79         {
  80             try
  81             {
  82                 System.out.print("==> ");
  83                 System.out.flush();
  84                 line = in.readLine();
  85                 if(line == null)
  86                 {
  87                     break;
  88                 }
  89                 if(line.equals("t"))
  90                 {
  91                     twoway.sayHello();
  92                 }
  93                 else if(line.equals("o"))
  94                 {
  95                     oneway.sayHello();
  96                 }
  97                 else if(line.equals("O"))
  98                 {
  99                     batchOneway.sayHello();
 100                 }
 101                 else if(line.equals("d"))
 102                 {
 103                     datagram.sayHello();
 104                 }
 105                 else if(line.equals("D"))
 106                 {
 107                     batchDatagram.sayHello();
 108                 }
 109                 else if(line.equals("f"))
 110                 {
 111                     communicator().flushBatchRequests();
 112                 }
 113                 else if(line.equals("x"))
 114                 {
 115                     // Nothing to do
 116                 }
 117                 else if(line.equals("?"))
 118                 {
 119                     menu();
 120                 }
 121                 else
 122                 {
 123                     System.out.println("unknown command `" + line + "'");
 124                     menu();
 125                 }
 126             }
 127             catch(java.io.IOException ex)
 128             {
 129                 ex.printStackTrace();
 130             }
 131             catch(Ice.LocalException ex)
 132             {
 133                 ex.printStackTrace();
 134             }
 135         }
 136         while(!line.equals("x"));
 137
 138         return 0;
 139     }
 140
 141     public static void
 142     main(String[] args)
 143     {
 144         Client app = new Client();
 145         int status = app.main("Client", args, "config.client");
 146         System.exit(status);
 147     }
 148 }