/*- * ============LICENSE_START======================================================= * openECOMP : APP-C * ================================================================================ * Copyright (C) 2017 AT&T Intellectual Property. All rights * reserved. * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * ============LICENSE_END========================================================= */ package org.openecomp.appc.adapter.rest; import org.openecomp.appc.Constants; import org.openecomp.appc.adapter.rest.impl.RestAdapterImpl; import org.openecomp.appc.configuration.Configuration; import org.openecomp.appc.configuration.ConfigurationFactory; import org.openecomp.appc.i18n.Msg; import com.att.eelf.configuration.EELFLogger; import com.att.eelf.configuration.EELFManager; import org.osgi.framework.BundleActivator; import org.osgi.framework.BundleContext; import org.osgi.framework.ServiceRegistration; /** * This activator is used to initialize and terminate the connection pool to one or more providers. *

* The CDP abstraction layer supports multiple types of providers, with each provider supporting multiple tenants. The * "connection" to a specific tenant on a specific provider is represented by a "context" object. These context objects * are authenticated to a specific tenant on the provider, but can be reused from one request to another. Contexts are * slow to set up and are resource intensive, so they are cached. However, the contexts for a specific tenant on a * specific provider must be cached separately. *

*

* Activation of the bundle creates an empty cache which is organized first by provider type, then by tenant name, with * the contents being an empty pool of contexts for that provider/tenant combination. The pool is created on first use, * and retained for as long as the bundle is active. *

*

* When the bundle is deactivated, the cache is torn down with all contexts being closed. *

*/ public class RestActivator implements BundleActivator { /** * The bundle registration */ private ServiceRegistration registration = null; /** * The reference to the actual implementation object that implements the services */ private RestAdapter adapter; /** * The logger to be used */ // private static final Logger LOG = LoggerFactory.getLogger(RestActivator.class); private static final EELFLogger logger = EELFManager.getInstance().getLogger(RestActivator.class); /** * The configuration object used to configure this bundle */ private Configuration configuration; /** * Called when this bundle is started so the Framework can perform the bundle-specific activities necessary to start * this bundle. This method can be used to register services or to allocate any resources that this bundle needs. *

* This method must complete and return to its caller in a timely manner. *

* * @param context * The execution context of the bundle being started. * @throws java.lang.Exception * If this method throws an exception, this bundle is marked as stopped and the Framework will remove * this bundle's listeners, unregister all services registered by this bundle, and release all services * used by this bundle. * @see org.osgi.framework.BundleActivator#start(org.osgi.framework.BundleContext) */ @Override public void start(BundleContext context) throws Exception { logger.info("Starting bundle " + getName()); configuration = ConfigurationFactory.getConfiguration(); String appName = configuration.getProperty(Constants.PROPERTY_APPLICATION_NAME); logger.info(Msg.COMPONENT_INITIALIZING, appName, "rest adapter"); adapter = new RestAdapterImpl(configuration.getProperties()); if (registration == null) { logger.info(Msg.REGISTERING_SERVICE, appName, adapter.getAdapterName(), RestAdapter.class.getSimpleName()); registration = context.registerService(RestAdapter.class, adapter, null); } logger.info(Msg.COMPONENT_INITIALIZED, appName, "REST adapter"); } /** * Called when this bundle is stopped so the Framework can perform the bundle-specific activities necessary to stop * the bundle. In general, this method should undo the work that the BundleActivator.start method started. There * should be no active threads that were started by this bundle when this bundle returns. A stopped bundle must not * call any Framework objects. *

* This method must complete and return to its caller in a timely manner. *

* * @param context * The execution context of the bundle being stopped. * @throws java.lang.Exception * If this method throws an exception, the bundle is still marked as stopped, and the Framework will * remove the bundle's listeners, unregister all services registered by the bundle, and release all * services used by the bundle. * * @see org.osgi.framework.BundleActivator#stop(org.osgi.framework.BundleContext) */ @Override public void stop(BundleContext context) throws Exception { logger.info("Stopping bundle " + getName()); if (registration != null) { String appName = configuration.getProperty(Constants.PROPERTY_APPLICATION_NAME); logger.info(Msg.COMPONENT_TERMINATING, appName, "REST adapter"); logger.info(Msg.UNREGISTERING_SERVICE, appName, adapter.getAdapterName()); registration.unregister(); registration = null; logger.info(Msg.COMPONENT_TERMINATED, appName, "REST adapter"); } } public String getName() { return "APPC IaaS adapter"; } }