summaryrefslogtreecommitdiff
path: root/java/src/IceInternal/ObjectAdapterFactory.java
diff options
context:
space:
mode:
authorDwayne Boone <dwayne@zeroc.com>2006-04-12 17:32:00 +0000
committerDwayne Boone <dwayne@zeroc.com>2006-04-12 17:32:00 +0000
commitb764fe6ce04b1367522a20a518933cca3ae54c66 (patch)
tree9334709074a791244c90a5ea78240ba930a93524 /java/src/IceInternal/ObjectAdapterFactory.java
parentFix (diff)
downloadice-b764fe6ce04b1367522a20a518933cca3ae54c66.tar.bz2
ice-b764fe6ce04b1367522a20a518933cca3ae54c66.tar.xz
ice-b764fe6ce04b1367522a20a518933cca3ae54c66.zip
Added createObjectAdapterWithRouter
Diffstat (limited to 'java/src/IceInternal/ObjectAdapterFactory.java')
-rw-r--r--java/src/IceInternal/ObjectAdapterFactory.java15
1 files changed, 13 insertions, 2 deletions
diff --git a/java/src/IceInternal/ObjectAdapterFactory.java b/java/src/IceInternal/ObjectAdapterFactory.java
index dd72b720636..060201bbb68 100644
--- a/java/src/IceInternal/ObjectAdapterFactory.java
+++ b/java/src/IceInternal/ObjectAdapterFactory.java
@@ -114,7 +114,7 @@ public final class ObjectAdapterFactory
}
public synchronized Ice.ObjectAdapter
- createObjectAdapter(String name, String endpoints)
+ createObjectAdapter(String name, String endpoints, Ice.RouterPrx router)
{
if(_instance == null)
{
@@ -127,7 +127,7 @@ public final class ObjectAdapterFactory
throw new Ice.AlreadyRegisteredException("object adapter", name);
}
- adapter = new Ice.ObjectAdapterI(_instance, _communicator, name, endpoints);
+ adapter = new Ice.ObjectAdapterI(_instance, _communicator, this, name, endpoints, router);
_adapters.put(name, adapter);
return adapter;
}
@@ -160,6 +160,17 @@ public final class ObjectAdapterFactory
return null;
}
+ public synchronized void
+ removeObjectAdapter(String name)
+ {
+ if(_waitForShutdown)
+ {
+ return;
+ }
+
+ _adapters.remove(name);
+ }
+
public void
flushBatchRequests()
{