diff options
| author | Mark Spruiell <mes@zeroc.com> | 2007-01-30 00:43:26 +0000 |
|---|---|---|
| committer | Mark Spruiell <mes@zeroc.com> | 2007-01-30 00:43:26 +0000 |
| commit | c7b49d03976e8fdae4102f61da1c3cab2b64873e (patch) | |
| tree | fea305f9f801cd11681152619b2f45d7fbabb5f5 /java/test/Ice/binding/RemoteCommunicatorI.java | |
| parent | skip this test for JDK 1.4 + SSL (diff) | |
| download | ice-c7b49d03976e8fdae4102f61da1c3cab2b64873e.tar.bz2 ice-c7b49d03976e8fdae4102f61da1c3cab2b64873e.tar.xz ice-c7b49d03976e8fdae4102f61da1c3cab2b64873e.zip | |
use thread model consistently
Diffstat (limited to 'java/test/Ice/binding/RemoteCommunicatorI.java')
| -rw-r--r-- | java/test/Ice/binding/RemoteCommunicatorI.java | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/java/test/Ice/binding/RemoteCommunicatorI.java b/java/test/Ice/binding/RemoteCommunicatorI.java index 6708aa99249..ada63c2abb2 100644 --- a/java/test/Ice/binding/RemoteCommunicatorI.java +++ b/java/test/Ice/binding/RemoteCommunicatorI.java @@ -15,7 +15,10 @@ public class RemoteCommunicatorI extends _RemoteCommunicatorDisp createObjectAdapter(String name, String endpoints, Ice.Current current) { Ice.Communicator com = current.adapter.getCommunicator(); - com.getProperties().setProperty("Ice.OA." + name + ".ThreadPool.Size", "1"); + if(com.getProperties().getPropertyAsIntWithDefault("Ice.ThreadPerConnection", 0) == 0) + { + com.getProperties().setProperty("Ice.OA." + name + ".ThreadPool.Size", "1"); + } Ice.ObjectAdapter adapter = com.createObjectAdapterWithEndpoints(name, endpoints); return RemoteObjectAdapterPrxHelper.uncheckedCast( current.adapter.addWithUUID(new RemoteObjectAdapterI(adapter))); @@ -32,4 +35,4 @@ public class RemoteCommunicatorI extends _RemoteCommunicatorDisp { current.adapter.getCommunicator().shutdown(); } -}; +} |