updated java impl.

1 files changed, 8 insertions, 1 deletions

diff --git a/java/demo/Ice/session/SessionFactoryI.java b/java/demo/Ice/session/SessionFactoryI.java
index 417e5800984..34a04ff113e 100644
--- a/java/demo/Ice/session/SessionFactoryI.java
+++ b/java/demo/Ice/session/SessionFactoryI.java
@@ -11,12 +11,17 @@ import Demo.*;
 
 class SessionFactoryI extends _SessionFactoryDisp
 {
+    SessionFactoryI(ReapThread reaper)
+    {
+	_reaper = reaper;
+    }
+
     public synchronized SessionPrx
     create(String name, Ice.Current c)
     {
 	SessionI session = new SessionI(name);
 	SessionPrx proxy = SessionPrxHelper.uncheckedCast(c.adapter.addWithUUID(session));
-	ReapThread.instance().add(proxy, session);
+	_reaper.add(proxy, session);
 	return proxy;
     }
 
@@ -26,4 +31,6 @@ class SessionFactoryI extends _SessionFactoryDisp
 	System.out.println("Shutting down...");
 	c.adapter.getCommunicator().shutdown();
     }
+
+    private ReapThread _reaper;
 }