java/test/Ice/background/Server.java

   1 // **********************************************************************
   2 //
   3 // Copyright (c) 2003-2011 ZeroC, Inc. All rights reserved.
   4 //
   5 // This copy of Ice is licensed to you under the terms described in the
   6 // ICE_LICENSE file included in this distribution.
   7 //
   8 // **********************************************************************
   9 package test.Ice.background;
  10
  11 import test.Ice.background.PluginFactory.PluginI;
  12
  13 public class Server extends test.Util.Application
  14 {
  15     static public class LocatorI extends Ice._LocatorDisp
  16     {
  17         public void
  18         findAdapterById_async(Ice.AMD_Locator_findAdapterById response, String adapter, Ice.Current current)
  19             throws Ice.AdapterNotFoundException
  20         {
  21             _controller.checkCallPause(current);
  22             Ice.Communicator communicator = current.adapter.getCommunicator();
  23             response.ice_response(current.adapter.createDirectProxy(communicator.stringToIdentity("dummy")));
  24         }
  25
  26         public void
  27         findObjectById_async(Ice.AMD_Locator_findObjectById response, Ice.Identity id, Ice.Current current)
  28             throws Ice.ObjectNotFoundException
  29         {
  30             _controller.checkCallPause(current);
  31             response.ice_response(current.adapter.createDirectProxy(id));
  32         }
  33
  34         public Ice.LocatorRegistryPrx
  35         getRegistry(Ice.Current current)
  36         {
  37             return null;
  38         }
  39
  40         LocatorI(BackgroundControllerI controller)
  41         {
  42             _controller = controller;
  43         }
  44
  45         final private BackgroundControllerI _controller;
  46     }
  47
  48     static public class RouterI extends Ice._RouterDisp
  49     {
  50         public Ice.ObjectPrx
  51         getClientProxy(Ice.Current current)
  52         {
  53             _controller.checkCallPause(current);
  54             return null;
  55         }
  56
  57         public Ice.ObjectPrx
  58         getServerProxy(Ice.Current current)
  59         {
  60             _controller.checkCallPause(current);
  61             return null;
  62         }
  63
  64         /**
  65          * @deprecated addProxy() is deprecated, use addProxies() instead.
  66          **/
  67         public void
  68         addProxy(Ice.ObjectPrx proxy, Ice.Current current)
  69         {
  70         }
  71
  72         public Ice.ObjectPrx[]
  73         addProxies(Ice.ObjectPrx[] proxies, Ice.Current current)
  74         {
  75             return new Ice.ObjectPrx[0];
  76         }
  77
  78         RouterI(BackgroundControllerI controller)
  79         {
  80             _controller = controller;
  81         }
  82
  83         final private BackgroundControllerI _controller;
  84     }
  85
  86     public int
  87     run(String[] args)
  88     {
  89         Configuration configuration = new Configuration();
  90         PluginI plugin = (PluginI)communicator().getPluginManager().getPlugin("Test");
  91         plugin.setConfiguration(configuration);
  92         communicator().getPluginManager().initializePlugins();
  93
  94         Ice.ObjectAdapter adapter = communicator().createObjectAdapter("TestAdapter");
  95         Ice.ObjectAdapter adapter2 = communicator().createObjectAdapter("ControllerAdapter");
  96
  97         BackgroundControllerI backgroundController = new BackgroundControllerI(configuration, adapter);
  98
  99         adapter.add(new BackgroundI(backgroundController), communicator().stringToIdentity("background"));
 100         adapter.add(new LocatorI(backgroundController), communicator().stringToIdentity("locator"));
 101         adapter.add(new RouterI(backgroundController), communicator().stringToIdentity("router"));
 102         adapter.activate();
 103
 104         adapter2.add(backgroundController, communicator().stringToIdentity("backgroundController"));
 105         adapter2.activate();
 106
 107         return WAIT;
 108     }
 109
 110     protected Ice.InitializationData getInitData(Ice.StringSeqHolder argsH)
 111     {
 112         Ice.InitializationData initData = new Ice.InitializationData();
 113         initData.properties = Ice.Util.createProperties(argsH);
 114
 115         //
 116         // This test kills connections, so we don't want warnings.
 117         //
 118         initData.properties.setProperty("Ice.Warn.Connections", "0");
 119
 120         //
 121         // Setup the test transport plug-in.
 122         //
 123         initData.properties.setProperty("Ice.Plugin.Test", "test.Ice.background.PluginFactory");
 124         String defaultProtocol = initData.properties.getPropertyWithDefault("Ice.Default.Protocol", "tcp");
 125         initData.properties.setProperty("Ice.Default.Protocol", "test-" + defaultProtocol);
 126
 127         initData.properties.setProperty("Ice.Package.Test", "test.Ice.background");
 128
 129         initData.properties.setProperty("TestAdapter.Endpoints", "default -p 12010");
 130         initData.properties.setProperty("ControllerAdapter.Endpoints", "tcp -p 12011");
 131         initData.properties.setProperty("ControllerAdapter.ThreadPool.Size", "1");
 132
 133         // Don't initialize the plugin until I've set the configuration.
 134         initData.properties.setProperty("Ice.InitPlugins", "0");
 135
 136         return initData;
 137     }
 138
 139     public static void
 140     main(String[] args)
 141     {
 142         Server app = new Server();
 143         int result = app.main("Server", args);
 144         System.gc();
 145         System.exit(result);
 146     }
 147 }