diff options
author | Joe George <joe@zeroc.com> | 2015-03-03 17:30:50 -0500 |
---|---|---|
committer | Joe George <joe@zeroc.com> | 2015-05-12 11:41:55 -0400 |
commit | d35bb9f5c19e34aee31f83d445695a8186ef675e (patch) | |
tree | d5324eaf44f5f9776495537c51653f50a66a7237 /java/test/IceSSL/configuration/ServerFactoryI.java | |
download | ice-d35bb9f5c19e34aee31f83d445695a8186ef675e.tar.bz2 ice-d35bb9f5c19e34aee31f83d445695a8186ef675e.tar.xz ice-d35bb9f5c19e34aee31f83d445695a8186ef675e.zip |
Ice 3.4.2 Source Distributionv3.4.2
Diffstat (limited to 'java/test/IceSSL/configuration/ServerFactoryI.java')
-rw-r--r-- | java/test/IceSSL/configuration/ServerFactoryI.java | 67 |
1 files changed, 67 insertions, 0 deletions
diff --git a/java/test/IceSSL/configuration/ServerFactoryI.java b/java/test/IceSSL/configuration/ServerFactoryI.java new file mode 100644 index 00000000000..5fea8ed544a --- /dev/null +++ b/java/test/IceSSL/configuration/ServerFactoryI.java @@ -0,0 +1,67 @@ +// ********************************************************************** +// +// Copyright (c) 2003-2011 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. +// +// ********************************************************************** + +package test.IceSSL.configuration; +import test.IceSSL.configuration.Test.ServerPrx; +import test.IceSSL.configuration.Test.ServerPrxHelper; +import test.IceSSL.configuration.Test._ServerFactoryDisp; + +class ServerFactoryI extends _ServerFactoryDisp +{ + private static void + test(boolean b) + { + if(!b) + { + throw new RuntimeException(); + } + } + + public ServerPrx + createServer(java.util.Map<String, String> props, Ice.Current current) + { + Ice.InitializationData initData = new Ice.InitializationData(); + initData.properties = Ice.Util.createProperties(); + for(java.util.Map.Entry<String, String> i : props.entrySet()) + { + initData.properties.setProperty(i.getKey(), i.getValue()); + } + + String[] args = new String[0]; + Ice.Communicator communicator = Ice.Util.initialize(args, initData); + Ice.ObjectAdapter adapter = communicator.createObjectAdapterWithEndpoints("ServerAdapter", "ssl"); + ServerI server = new ServerI(communicator); + Ice.ObjectPrx obj = adapter.addWithUUID(server); + _servers.put(obj.ice_getIdentity(), server); + adapter.activate(); + + return ServerPrxHelper.uncheckedCast(obj); + } + + public void + destroyServer(ServerPrx srv, Ice.Current current) + { + Ice.Identity key = srv.ice_getIdentity(); + if(_servers.containsKey(key)) + { + ServerI server = _servers.get(key); + server.destroy(); + _servers.remove(key); + } + } + + public void + shutdown(Ice.Current current) + { + test(_servers.size() == 0); + current.adapter.getCommunicator().shutdown(); + } + + private java.util.Map<Ice.Identity, ServerI> _servers = new java.util.HashMap<Ice.Identity, ServerI>(); +} |