X-Git-Url: https://git.argeo.org/?a=blobdiff_plain;ds=inline;f=eclipse%2Fruntime%2Forg.argeo.eclipse.ui%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Feclipse%2Fspring%2FApplicationContextTracker.java;fp=eclipse%2Fruntime%2Forg.argeo.eclipse.ui%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Feclipse%2Fspring%2FApplicationContextTracker.java;h=805d11d8a580632bc71acc7eb72bc2e19f8e35fc;hb=92daeb190be66653f39544ae9b5a2f2c31a60797;hp=0000000000000000000000000000000000000000;hpb=ca8f7ca09374e7de429c83894cf9fcb77892a879;p=lgpl%2Fargeo-commons.git

diff --git a/eclipse/runtime/org.argeo.eclipse.ui/src/main/java/org/argeo/eclipse/spring/ApplicationContextTracker.java b/eclipse/runtime/org.argeo.eclipse.ui/src/main/java/org/argeo/eclipse/spring/ApplicationContextTracker.java
new file mode 100644
index 000000000..805d11d8a
--- /dev/null
+++ b/eclipse/runtime/org.argeo.eclipse.ui/src/main/java/org/argeo/eclipse/spring/ApplicationContextTracker.java
@@ -0,0 +1,124 @@
+/*
+ * Copyright (C) 2010 Mathieu Baudier <mbaudier@argeo.org>
+ *
+ * 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.
+ */
+
+package org.argeo.eclipse.spring;
+
+import static java.text.MessageFormat.format;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.eclipse.core.runtime.Platform;
+import org.osgi.framework.Bundle;
+import org.osgi.framework.BundleContext;
+import org.osgi.framework.BundleException;
+import org.osgi.framework.FrameworkUtil;
+import org.osgi.framework.InvalidSyntaxException;
+import org.osgi.util.tracker.ServiceTracker;
+import org.springframework.context.ApplicationContext;
+
+/**
+ * @author Heiko Seeberger
+ * @author Mathieu Baudier
+ */
+class ApplicationContextTracker {
+	private final static Log log = LogFactory
+			.getLog(ApplicationContextTracker.class);
+
+	private static final String FILTER = "(&(objectClass=org.springframework.context.ApplicationContext)" //$NON-NLS-1$
+			+ "(org.springframework.context.service.name={0}))"; //$NON-NLS-1$
+
+	private ServiceTracker applicationContextServiceTracker;
+
+	/**
+	 * @param contributorBundle
+	 *            OSGi bundle for which the Spring application context is to be
+	 *            tracked. Must not be null!
+	 * @param factoryBundleContext
+	 *            BundleContext object which can be used to track services
+	 * @throws IllegalArgumentException
+	 *             if the given bundle is null.
+	 */
+	public ApplicationContextTracker(final Bundle contributorBundle,
+			final BundleContext factoryBundleContext) {
+		final String filter = format(FILTER,
+				contributorBundle.getSymbolicName());
+		try {
+			applicationContextServiceTracker = new ServiceTracker(
+					factoryBundleContext, FrameworkUtil.createFilter(filter),
+					null);
+			applicationContextServiceTracker.open();
+		} catch (final InvalidSyntaxException e) {
+			e.printStackTrace();
+		}
+	}
+
+	public void close() {
+		if (applicationContextServiceTracker != null) {
+			applicationContextServiceTracker.close();
+		}
+	}
+
+	public ApplicationContext getApplicationContext() {
+		ApplicationContext applicationContext = null;
+		if (applicationContextServiceTracker != null) {
+			try {
+				applicationContext = (ApplicationContext) applicationContextServiceTracker
+						.waitForService(5000);
+			} catch (InterruptedException e) {
+				e.printStackTrace();
+			}
+		}
+		return applicationContext;
+	}
+
+	@Override
+	protected void finalize() throws Throwable {
+		close();
+		super.finalize();
+	}
+
+	static ApplicationContext getApplicationContext(String bundleSymbolicName) {
+		Bundle contributorBundle = Platform.getBundle(bundleSymbolicName);
+		return getApplicationContext(contributorBundle);
+	}
+
+	static ApplicationContext getApplicationContext(Bundle contributorBundle) {
+		if (log.isTraceEnabled())
+			log.trace("Get application context for bundle " + contributorBundle);
+
+		if (contributorBundle.getState() != Bundle.ACTIVE
+				&& contributorBundle.getState() != Bundle.STARTING) {
+			try {
+				log.info("Starting bundle: "
+						+ contributorBundle.getSymbolicName());
+				contributorBundle.start();
+			} catch (BundleException e) {
+				e.printStackTrace();
+			}
+		}
+
+		final ApplicationContextTracker applicationContextTracker = new ApplicationContextTracker(
+				contributorBundle, contributorBundle.getBundleContext());
+		ApplicationContext applicationContext = null;
+		try {
+			applicationContext = applicationContextTracker
+					.getApplicationContext();
+		} finally {
+			applicationContextTracker.close();
+		}
+		return applicationContext;
+	}
+}