diff options
Diffstat (limited to 'java/sca/modules/node-launcher-equinox/src/main/java/org/apache/tuscany/sca/node/equinox/launcher/FrameworkLauncher.java')
-rw-r--r-- | java/sca/modules/node-launcher-equinox/src/main/java/org/apache/tuscany/sca/node/equinox/launcher/FrameworkLauncher.java | 252 |
1 files changed, 126 insertions, 126 deletions
diff --git a/java/sca/modules/node-launcher-equinox/src/main/java/org/apache/tuscany/sca/node/equinox/launcher/FrameworkLauncher.java b/java/sca/modules/node-launcher-equinox/src/main/java/org/apache/tuscany/sca/node/equinox/launcher/FrameworkLauncher.java index 777ab59df3..380056e470 100644 --- a/java/sca/modules/node-launcher-equinox/src/main/java/org/apache/tuscany/sca/node/equinox/launcher/FrameworkLauncher.java +++ b/java/sca/modules/node-launcher-equinox/src/main/java/org/apache/tuscany/sca/node/equinox/launcher/FrameworkLauncher.java @@ -1,126 +1,126 @@ -/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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.apache.tuscany.sca.node.equinox.launcher;
-
-import java.io.BufferedReader;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.InputStreamReader;
-import java.util.Hashtable;
-import java.util.Map;
-import java.util.logging.Level;
-import java.util.logging.Logger;
-
-import org.eclipse.osgi.framework.console.CommandProvider;
-import org.osgi.framework.BundleActivator;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.launch.Framework;
-import org.osgi.framework.launch.FrameworkFactory;
-
-/**
- * Launcher for the OSGi framework using the framework launch APIs
- */
-public class FrameworkLauncher implements BundleActivator {
- private static final Logger logger = Logger.getLogger(FrameworkLauncher.class.getName());
-
- private FrameworkFactory factory;
- private boolean isEquinox;
-
- @SuppressWarnings("unchecked")
- private synchronized FrameworkFactory loadFrameworkFactory() {
- if (factory == null) {
- // Use reflection APIs to call ServiceDiscovery to avoid hard dependency to tuscany-extensibility
- try {
- ClassLoader classLoader = Thread.currentThread().getContextClassLoader();
- InputStream is =
- classLoader.getResourceAsStream("META-INF/services/" + FrameworkFactory.class.getName());
- if (is == null) {
- classLoader = FrameworkFactory.class.getClassLoader();
- is = classLoader.getResourceAsStream("META-INF/services/" + FrameworkFactory.class.getName());
- }
- if (is == null) {
- return null;
- }
- BufferedReader reader = null;
- String line = null;
- try {
- reader = new BufferedReader(new InputStreamReader(is));
- while (true) {
- line = reader.readLine();
- if (line == null)
- break;
- line = line.trim();
- if (!line.startsWith("#") && !"".equals(line)) {
- break;
- }
- }
- } finally {
- if (reader != null) {
- try {
- reader.close();
- } catch (IOException e) {
- // Ignore
- }
- }
- }
- if (line != null) {
- Class<? extends FrameworkFactory> factoryImplClass =
- (Class<? extends FrameworkFactory>)Class.forName(line, false, classLoader);
- factory = factoryImplClass.newInstance();
- if (factory != null && factory.getClass().getName().startsWith("org.eclipse.osgi.")) {
- isEquinox = true;
- }
-
- }
- } catch (Throwable e) {
- logger.log(Level.SEVERE, e.getMessage(), e);
- }
- }
- return factory;
- }
-
- public Framework newFramework(Map properties) {
- FrameworkFactory factory = loadFrameworkFactory();
- if (factory == null) {
- return null;
- }
- return factory.newFramework(properties);
- }
-
- public boolean isEquinox() {
- return isEquinox;
- }
-
- public void start(BundleContext context) throws Exception {
- EquinoxHost.injectedBundleContext = context;
- if (context.getClass().getName().startsWith("org.eclipse.osgi.")) {
- isEquinox = true;
- try {
- context.registerService(CommandProvider.class.getName(), new NodeLauncherCommand(), new Hashtable());
- } catch (NoClassDefFoundError e) {
- // Ignore it
- }
- }
- }
-
- public void stop(BundleContext context) throws Exception {
- EquinoxHost.injectedBundleContext = null;
- }
-}
+/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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.apache.tuscany.sca.node.equinox.launcher; + +import java.io.BufferedReader; +import java.io.IOException; +import java.io.InputStream; +import java.io.InputStreamReader; +import java.util.Hashtable; +import java.util.Map; +import java.util.logging.Level; +import java.util.logging.Logger; + +import org.eclipse.osgi.framework.console.CommandProvider; +import org.osgi.framework.BundleActivator; +import org.osgi.framework.BundleContext; +import org.osgi.framework.launch.Framework; +import org.osgi.framework.launch.FrameworkFactory; + +/** + * Launcher for the OSGi framework using the framework launch APIs + */ +public class FrameworkLauncher implements BundleActivator { + private static final Logger logger = Logger.getLogger(FrameworkLauncher.class.getName()); + + private FrameworkFactory factory; + private boolean isEquinox; + + @SuppressWarnings("unchecked") + private synchronized FrameworkFactory loadFrameworkFactory() { + if (factory == null) { + // Use reflection APIs to call ServiceDiscovery to avoid hard dependency to tuscany-extensibility + try { + ClassLoader classLoader = Thread.currentThread().getContextClassLoader(); + InputStream is = + classLoader.getResourceAsStream("META-INF/services/" + FrameworkFactory.class.getName()); + if (is == null) { + classLoader = FrameworkFactory.class.getClassLoader(); + is = classLoader.getResourceAsStream("META-INF/services/" + FrameworkFactory.class.getName()); + } + if (is == null) { + return null; + } + BufferedReader reader = null; + String line = null; + try { + reader = new BufferedReader(new InputStreamReader(is)); + while (true) { + line = reader.readLine(); + if (line == null) + break; + line = line.trim(); + if (!line.startsWith("#") && !"".equals(line)) { + break; + } + } + } finally { + if (reader != null) { + try { + reader.close(); + } catch (IOException e) { + // Ignore + } + } + } + if (line != null) { + Class<? extends FrameworkFactory> factoryImplClass = + (Class<? extends FrameworkFactory>)Class.forName(line, false, classLoader); + factory = factoryImplClass.newInstance(); + if (factory != null && factory.getClass().getName().startsWith("org.eclipse.osgi.")) { + isEquinox = true; + } + + } + } catch (Throwable e) { + logger.log(Level.SEVERE, e.getMessage(), e); + } + } + return factory; + } + + public Framework newFramework(Map properties) { + FrameworkFactory factory = loadFrameworkFactory(); + if (factory == null) { + return null; + } + return factory.newFramework(properties); + } + + public boolean isEquinox() { + return isEquinox; + } + + public void start(BundleContext context) throws Exception { + EquinoxHost.injectedBundleContext = context; + if (context.getClass().getName().startsWith("org.eclipse.osgi.")) { + isEquinox = true; + try { + context.registerService(CommandProvider.class.getName(), new NodeLauncherCommand(), new Hashtable()); + } catch (NoClassDefFoundError e) { + // Ignore it + } + } + } + + public void stop(BundleContext context) throws Exception { + EquinoxHost.injectedBundleContext = null; + } +} |