summaryrefslogtreecommitdiff
path: root/java/demo/Ice/session/SessionFactoryI.java
diff options
context:
space:
mode:
Diffstat (limited to 'java/demo/Ice/session/SessionFactoryI.java')
-rw-r--r--java/demo/Ice/session/SessionFactoryI.java9
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;
}