added session demo.

1 files changed, 230 insertions, 0 deletions

diff --git a/java/demo/Ice/session/Client.java b/java/demo/Ice/session/Client.java
new file mode 100644
index 00000000000..c9bd29a7a36
--- /dev/null
+++ b/java/demo/Ice/session/Client.java
@@ -0,0 +1,230 @@
+// **********************************************************************
+//
+// 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.*;
+
+public class Client
+{
+    static private class SessionRefreshThread extends Thread
+    {
+	SessionRefreshThread(Ice.Logger logger, long timeout, SessionPrx session)
+	{
+	    _logger = logger;
+	    _session = session;
+	    _timeout = timeout;
+	}
+
+	synchronized public void
+	run()
+	{
+	    while(!_terminated)
+	    {
+		try
+		{
+		    wait(_timeout);
+		}
+		catch(InterruptedException e)
+		{
+		}
+		if(_terminated)
+		{
+		    break;
+		}
+		try
+		{
+		    _session.refresh();
+		}
+		catch(Ice.LocalException ex)
+		{
+		    _logger.warning("SessionRefreshThread: " + ex);
+		    break;
+		}
+	    }
+	}
+
+	synchronized private void
+	terminate()
+	{
+	    _terminated = true;
+	    notify();
+	}
+
+	final private Ice.Logger _logger;
+	final private SessionPrx _session;
+	final private long _timeout;
+	private boolean _terminated = false;
+    }
+
+    private static void
+    menu()
+    {
+        System.out.println(
+	    "usage:\n" +
+	    "c:     create new hello\n" +
+	    "0-9:   greet hello object\n" +
+	    "s:     shutdown server\n" +
+	    "x:     exit\n" +
+	    "t:     exit without destroying the session\n" +
+	    "?:     help\n");
+    }
+
+    private static int
+    run(String[] args, Ice.Communicator communicator)
+    {
+        Ice.Properties properties = communicator.getProperties();
+        final String proxyProperty = "SessionFactory.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);
+        SessionFactoryPrx factory = SessionFactoryPrxHelper.checkedCast(base);
+        if(factory == null)
+        {
+            System.err.println("invalid proxy");
+            return 1;
+        }
+
+    	SessionPrx session = factory.create();
+    	SessionRefreshThread refresh = new SessionRefreshThread(communicator.getLogger(), 5000, session);
+    	refresh.start();
+
+    	java.util.ArrayList hellos = new java.util.ArrayList();
+
+        menu();
+
+        java.io.BufferedReader in = new java.io.BufferedReader(new java.io.InputStreamReader(System.in));
+
+	try
+	{
+	    boolean destroy = true;
+	    while(true)
+	    {
+                System.out.print("==> ");
+                System.out.flush();
+		String line = in.readLine();
+                if(line == null)
+                {
+                    break;
+                }
+    	    	if(line.length() > 0 && Character.isDigit(line.charAt(0)))
+		{
+		    int index;
+		    try
+		    {
+			index = Integer.parseInt(line);
+		    }
+		    catch(NumberFormatException e)
+		    {
+			menu();
+			continue;
+		    }
+		    if(index < hellos.size())
+		    {
+			HelloPrx hello = (HelloPrx)hellos.get(index);
+			hello.sayHello();
+		    }
+		    else
+		    {
+			System.out.println("index is too high. " + hellos.size() + " exist so far. " +
+					   "Use 'c' to create a new hello object.");
+		    }
+		}
+                else if(line.equals("c"))
+                {
+                    hellos.add(session.createHello());
+    	    	    System.out.println("created hello object " + (hellos.size()-1));
+                }
+                else if(line.equals("s"))
+                {
+		    factory.shutdown();
+                }
+                else if(line.equals("x"))
+                {
+    	    	    break;
+                }
+                else if(line.equals("t"))
+                {
+		    destroy = false;
+		    break;
+                }
+                else if(line.equals("?"))
+                {
+                    menu();
+                }
+                else
+                {
+                    System.out.println("unknown command `" + line + "'");
+                    menu();
+                }
+            }
+    	    if(destroy)
+	    {
+		session.destroy();
+	    }
+	}
+	catch(java.io.IOException ex)
+	{
+	    ex.printStackTrace();
+	}
+	catch(Ice.LocalException ex)
+	{
+	    ex.printStackTrace();
+	}
+
+    	refresh.terminate();
+	try
+	{
+	    refresh.join();
+	}
+	catch(InterruptedException e)
+	{
+	}
+    
+        return 0;
+    }
+
+    public static void
+    main(String[] args)
+    {
+        int status = 0;
+        Ice.Communicator communicator = null;
+
+        try
+        {
+            Ice.Properties properties = Ice.Util.createProperties();
+            properties.load("config");
+            communicator = Ice.Util.initializeWithProperties(args, properties);
+            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);
+    }
+}