// ********************************************************************** // // Copyright (c) 2003-2009 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 Ice; public final class CommunicatorI implements Communicator { public void destroy() { _instance.destroy(); } public void shutdown() { _instance.objectAdapterFactory().shutdown(); } public void waitForShutdown() { _instance.objectAdapterFactory().waitForShutdown(); } public boolean isShutdown() { return _instance.objectAdapterFactory().isShutdown(); } public Ice.ObjectPrx stringToProxy(String s) { return _instance.proxyFactory().stringToProxy(s); } public String proxyToString(Ice.ObjectPrx proxy) { return _instance.proxyFactory().proxyToString(proxy); } public Ice.ObjectPrx propertyToProxy(String s) { return _instance.proxyFactory().propertyToProxy(s); } public Ice.Identity stringToIdentity(String s) { return _instance.stringToIdentity(s); } public String identityToString(Ice.Identity ident) { return _instance.identityToString(ident); } public ObjectAdapter createObjectAdapter(String name) { return _instance.objectAdapterFactory().createObjectAdapter(name, "", null); } public ObjectAdapter createObjectAdapterWithEndpoints(String name, String endpoints) { return _instance.objectAdapterFactory().createObjectAdapter(name, endpoints, null); } public ObjectAdapter createObjectAdapterWithRouter(String name, RouterPrx router) { return _instance.objectAdapterFactory().createObjectAdapter(name, "", router); } public void addObjectFactory(ObjectFactory factory, String id) { _instance.servantFactoryManager().add(factory, id); } public ObjectFactory findObjectFactory(String id) { return _instance.servantFactoryManager().find(id); } public Properties getProperties() { return _instance.initializationData().properties; } public Logger getLogger() { return _instance.initializationData().logger; } public Stats getStats() { return _instance.initializationData().stats; } public RouterPrx getDefaultRouter() { return _instance.referenceFactory().getDefaultRouter(); } public void setDefaultRouter(RouterPrx router) { _instance.setDefaultRouter(router); } public LocatorPrx getDefaultLocator() { return _instance.referenceFactory().getDefaultLocator(); } public void setDefaultLocator(LocatorPrx locator) { _instance.setDefaultLocator(locator); } /** * @deprecated **/ public java.util.Map getDefaultContext() { return _instance.getDefaultContext(); } /** * @deprecated **/ public void setDefaultContext(java.util.Map ctx) { _instance.setDefaultContext(ctx); } public ImplicitContext getImplicitContext() { return _instance.getImplicitContext(); } public PluginManager getPluginManager() { return _instance.pluginManager(); } public void flushBatchRequests() { _instance.flushBatchRequests(); } public ObjectPrx getAdmin() { return _instance.getAdmin(); } public void addAdminFacet(Object servant, String facet) { _instance.addAdminFacet(servant, facet); } public Object removeAdminFacet(String facet) { return _instance.removeAdminFacet(facet); } CommunicatorI(InitializationData initData) { _instance = new IceInternal.Instance(this, initData); } /** * For compatibility with C#, we do not invoke methods on other objects * from within a finalizer. * protected synchronized void finalize() throws Throwable { if(!_instance.destroyed()) { _instance.logger().warning("Ice::Communicator::destroy() has not been called"); } super.finalize(); } */ // // Certain initialization tasks need to be completed after the // constructor. // void finishSetup(StringSeqHolder args) { try { _instance.finishSetup(args); } catch(RuntimeException ex) { _instance.destroy(); throw ex; } } // // For use by Util.getInstance() // IceInternal.Instance getInstance() { return _instance; } private IceInternal.Instance _instance; }