bundles/org.eclipse.equinox.event/src/org/eclipse/equinox/internal/event/Activator.java

/*******************************************************************************
 * Copyright (c) 2005, 2018 IBM Corporation and others.
 *
 * This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License 2.0
 * which accompanies this distribution, and is available at
 * https://www.eclipse.org/legal/epl-2.0/
 *
 * SPDX-License-Identifier: EPL-2.0
 *
 * Contributors:
 *     IBM Corporation - initial API and implementation
 *******************************************************************************/

package org.eclipse.equinox.internal.event;

import org.osgi.framework.*;
import org.osgi.service.event.EventAdmin;

public class Activator implements BundleActivator {
	private static final String PROP_USE_DS = "equinox.use.ds"; //$NON-NLS-1$
	private ServiceRegistration<EventAdmin> eventAdminService;
	private EventComponent eventAdmin;

	@Override
	public void start(BundleContext bundleContext) throws InvalidSyntaxException {
		if (Boolean.valueOf(bundleContext.getProperty(PROP_USE_DS)).booleanValue())
			return; // If this property is set we assume DS is being used.
		String serviceName = EventAdmin.class.getName();
		Filter serviceFilter = bundleContext.createFilter("(objectclass=" + serviceName + ")"); //$NON-NLS-1$ //$NON-NLS-2$
		//don't register the service if this bundle has already registered it declaratively
		ServiceReference<?>[] refs = bundleContext.getBundle().getRegisteredServices();
		if (refs != null) {
			for (ServiceReference<?> ref : refs) {
				if (serviceFilter.match(ref)) {
					return; // We found a service registered by this bundle already
				}
			}
		}

		eventAdmin = new EventComponent();
		eventAdmin.activate(bundleContext);
		eventAdminService = bundleContext.registerService(EventAdmin.class, eventAdmin, null);
	}

	@Override
	public void stop(BundleContext bundleContext) {
		if (eventAdmin != null) {
			eventAdminService.unregister();
			eventAdmin.deactivate(bundleContext);
		}
	}
}