summaryrefslogtreecommitdiff
path: root/javae/demo/IceE/jdk/chat/Client.java
diff options
context:
space:
mode:
Diffstat (limited to 'javae/demo/IceE/jdk/chat/Client.java')
-rw-r--r--javae/demo/IceE/jdk/chat/Client.java191
1 files changed, 0 insertions, 191 deletions
diff --git a/javae/demo/IceE/jdk/chat/Client.java b/javae/demo/IceE/jdk/chat/Client.java
deleted file mode 100644
index 9bc4cbb1e9e..00000000000
--- a/javae/demo/IceE/jdk/chat/Client.java
+++ /dev/null
@@ -1,191 +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("enter /quit to exit.");
- }
-
- private static int
- run(String[] args, Ice.Communicator communicator)
- {
- 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));
-
- ChatSessionPrx session = null;
- while(true)
- {
- System.out.println("This demo accepts any user-id / password combination.");
-
- String id = null;
- String pw = null;
-
- try
- {
- System.out.print("user id: ");
- System.out.flush();
- id = in.readLine();
- id = id.trim();
-
- System.out.print("password: ");
- System.out.flush();
- pw = in.readLine();
- pw = pw.trim();
- }
- catch(java.io.IOException ex)
- {
- ex.printStackTrace();
- return 1;
- }
-
- try
- {
- session = ChatSessionPrxHelper.uncheckedCast(router.createSession(id, pw));
- break;
- }
- catch(Glacier2.CannotCreateSessionException ex)
- {
- ex.printStackTrace();
- }
- catch(Glacier2.PermissionDeniedException ex)
- {
- ex.printStackTrace();
- }
- }
-
- SessionPingThread ping = new SessionPingThread(session, router.getSessionTimeout() / 2);
- ping.start();
-
- String category = router.getServerProxy().ice_getIdentity().category;
- Ice.Identity callbackReceiverIdent = new Ice.Identity();
- callbackReceiverIdent.name = "callbackReceiver";
- callbackReceiverIdent.category = category;
-
- Ice.ObjectAdapter adapter = communicator.createObjectAdapter("Chat.Client");
- ChatCallbackPrx callback = ChatCallbackPrxHelper.uncheckedCast(
- adapter.add(new ChatCallbackI(), callbackReceiverIdent));
- adapter.activate();
-
- session.setCallback(callback);
-
- menu();
-
- try
- {
- String line = null;
- do
- {
- System.out.print("==> ");
- System.out.flush();
- line = in.readLine();
- if(line == null)
- {
- break;
- }
- line = line.trim();
-
- if(line.startsWith("/"))
- {
- if(line.equals("/quit"))
- {
- break;
- }
- else
- {
- menu();
- }
- }
- else
- {
- session.say(line);
- }
- }
- while(true);
-
- try
- {
- router.destroySession();
- }
- catch(Ice.ConnectionLostException ex)
- {
- //
- // Expected: the router closed the connection.
- //
- }
- }
- catch(Exception ex)
- {
- ex.printStackTrace();
- }
-
- ping.destroy();
- try
- {
- ping.join();
- }
- catch(java.lang.InterruptedException ex)
- {
- }
- 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);
- }
-}