added missing file.

1 files changed, 101 insertions, 0 deletions

diff --git a/java/demo/Ice/session/ReapThread.java b/java/demo/Ice/session/ReapThread.java
new file mode 100644
index 00000000000..2b5e22778d7
--- /dev/null
+++ b/java/demo/Ice/session/ReapThread.java
@@ -0,0 +1,101 @@
+// **********************************************************************
+//
+// 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 ReapThread extends Thread
+{ 
+    static class SessionProxyPair
+    {
+	SessionProxyPair(Demo.SessionPrx p, SessionI s)
+	{
+	    proxy = p;
+	    session = s;
+	}
+
+	Demo.SessionPrx proxy;
+	SessionI session;
+    };
+
+    synchronized public void
+    run()
+    {
+	while(!_terminated)
+	{
+	    try
+	    {
+		wait(_timeout);
+	    }
+	    catch(InterruptedException e)
+	    {
+	    }
+	    
+	    if(!_terminated)
+	    {
+		java.util.Iterator p = _sessions.iterator();
+		while(p.hasNext())
+		{
+		    SessionProxyPair s = (SessionProxyPair)p.next();
+		    try
+		    {
+			//
+			// Session destruction may take time in a
+			// real-world example. Therefore the current time
+			// is computed for each iteration.
+			//
+			if((System.currentTimeMillis() - s.session.timestamp()) > _timeout)
+			{
+			    String name = s.proxy.getName();
+			    s.proxy.destroy();
+			    System.out.println("The session " + name + " has timed out.");
+			    p.remove();
+			}
+		    }
+		    catch(Ice.ObjectNotExistException e)
+		    {
+			p.remove();
+		    }
+		}
+	    }
+	}
+    }
+
+    synchronized public void
+    terminate()
+    {
+	_terminated = true;
+	notify();
+	
+	java.util.Iterator p = _sessions.iterator();
+	while(p.hasNext())
+	{
+	    SessionProxyPair s = (SessionProxyPair)p.next();
+	    try
+	    {
+		s.proxy.destroy();
+	    }
+	    catch(Ice.LocalException e)
+	    {
+		// Ignore.
+	    }
+	}
+	
+	_sessions.clear();
+    }
+
+    synchronized public void
+    add(SessionPrx proxy, SessionI session)
+    {
+	_sessions.add(new SessionProxyPair(proxy, session));
+    }
+
+    private final long _timeout = 10 * 1000; // 10 seconds.
+    private boolean _terminated = false;
+    private java.util.List _sessions = new java.util.LinkedList();
+}