blob: dc29070639f0306b3ab4c5a72d64cd404bbd9437 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
|
// **********************************************************************
//
// Copyright (c) 2003-2007 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.
//
// **********************************************************************
class ServerFactoryI extends Test._ServerFactoryDisp
{
private static void
test(boolean b)
{
if(!b)
{
throw new RuntimeException();
}
}
public Test.ServerPrx
createServer(java.util.Map props, Ice.Current current)
{
Ice.InitializationData initData = new Ice.InitializationData();
initData.properties = Ice.Util.createProperties();
java.util.Iterator i = props.entrySet().iterator();
while(i.hasNext())
{
java.util.Map.Entry e = (java.util.Map.Entry)i.next();
initData.properties.setProperty((String)e.getKey(), (String)e.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 Test.ServerPrxHelper.uncheckedCast(obj);
}
public void
destroyServer(Test.ServerPrx srv, Ice.Current current)
{
Ice.Identity key = srv.ice_getIdentity();
if(_servers.containsKey(key))
{
ServerI server = (ServerI)_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.HashMap _servers = new java.util.HashMap();
}
|
