java/demo/Ice/async/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     public class Callback_Hello_sayHelloI extends Callback_Hello_sayHello
  31     {
  32         @Override
  33         public void response()
  34         {
  35         }
  36
  37         @Override
  38         public void exception(Ice.LocalException ex)
  39         {
  40             System.err.println("sayHello AMI call failed:");
  41             ex.printStackTrace();
  42         }
  43
  44         @Override
  45         public void exception(Ice.UserException ex)
  46         {
  47             if(ex instanceof Demo.RequestCanceledException)
  48             {
  49                 System.out.println("Demo.RequestCanceledException");
  50             }
  51             else
  52             {
  53                 ex.printStackTrace();
  54             }
  55         }
  56     }
  57
  58     private static void
  59     menu()
  60     {
  61         System.out.println(
  62             "usage:\n" +
  63             "i: send immediate greeting\n" +
  64             "d: send delayed greeting\n" +
  65             "s: shutdown the server\n" +
  66             "x: exit\n" +
  67             "?: help\n");
  68     }
  69
  70     public int
  71     run(String[] args)
  72     {
  73         if(args.length > 0)
  74         {
  75             System.err.println(appName() + ": too many arguments");
  76             return 1;
  77         }
  78
  79         //
  80         // Since this is an interactive demo we want to clear the
  81         // Application installed interrupt callback and install our
  82         // own shutdown hook.
  83         //
  84         setInterruptHook(new ShutdownHook());
  85
  86         HelloPrx hello = HelloPrxHelper.checkedCast(communicator().propertyToProxy("Hello.Proxy"));
  87         if(hello == null)
  88         {
  89             System.err.println("invalid proxy");
  90             return 1;
  91         }
  92
  93         menu();
  94
  95         java.io.BufferedReader in = new java.io.BufferedReader(new java.io.InputStreamReader(System.in));
  96
  97         String line = null;
  98         do
  99         {
 100             try
 101             {
 102                 System.out.print("==> ");
 103                 System.out.flush();
 104                 line = in.readLine();
 105                 if(line == null)
 106                 {
 107                     break;
 108                 }
 109                 if(line.equals("i"))
 110                 {
 111                     hello.sayHello(0);
 112                 }
 113                 else if(line.equals("d"))
 114                 {
 115                     hello.begin_sayHello(5000, new Callback_Hello_sayHelloI());
 116                 }
 117                 else if(line.equals("s"))
 118                 {
 119                     hello.shutdown();
 120                 }
 121                 else if(line.equals("x"))
 122                 {
 123                     // Nothing to do
 124                 }
 125                 else
 126                 {
 127                     System.out.println("unknown command `" + line + "'");
 128                     menu();
 129                 }
 130             }
 131             catch(java.io.IOException ex)
 132             {
 133                 ex.printStackTrace();
 134             }
 135             catch(Ice.UserException ex)
 136             {
 137                 ex.printStackTrace();
 138             }
 139             catch(Ice.LocalException ex)
 140             {
 141                 ex.printStackTrace();
 142             }
 143         }
 144         while(!line.equals("x"));
 145
 146         return 0;
 147     }
 148
 149     public static void
 150     main(String[] args)
 151     {
 152         Client app = new Client();
 153         int status = app.main("Client", args, "config.client");
 154         System.exit(status);
 155     }
 156 }