providers/bundles/org.eclipse.ecf.provider.filetransfer/src/org/eclipse/ecf/internal/provider/filetransfer/Activator.java - ecf/org.eclipse.ecf - Git at Google

 /****************************************************************************
  * Copyright (c) 2006, 2007 Composent, Inc. and others.
  * All rights reserved. This program and the accompanying materials
  * are made available under the terms of the Eclipse Public License v1.0
  * which accompanies this distribution, and is available at
  * http://www.eclipse.org/legal/epl-v10.html
  *
  * Contributors:
  *    Composent, Inc. - initial API and implementation
  *****************************************************************************/
 package org.eclipse.ecf.internal.provider.filetransfer;

 import java.io.IOException;
 import java.net.URL;
 import java.net.URLConnection;
 import java.util.*;
 import org.eclipse.core.net.proxy.IProxyService;
 import org.eclipse.core.runtime.*;
 import org.eclipse.ecf.core.util.LogHelper;
 import org.eclipse.ecf.core.util.PlatformHelper;
 import org.eclipse.ecf.filetransfer.service.*;
 import org.eclipse.ecf.provider.filetransfer.retrieve.MultiProtocolRetrieveAdapter;
 import org.eclipse.osgi.util.NLS;
 import org.osgi.framework.*;
 import org.osgi.service.log.LogService;
 import org.osgi.service.url.*;
 import org.osgi.util.tracker.ServiceTracker;

 /**
  * The activator class controls the plug-in life cycle
  */
 public class Activator implements BundleActivator {

 	private static final String CLASS_ATTR = "class"; //$NON-NLS-1$
 	private static final String PROTOCOL_ATTR = "protocol"; //$NON-NLS-1$
 	private static final String[] jvmSchemes = new String[] {Messages.FileTransferNamespace_Http_Protocol, Messages.FileTransferNamespace_Ftp_Protocol, Messages.FileTransferNamespace_File_Protocol, Messages.FileTransferNamespace_Jar_Protocol, Messages.FileTransferNamespace_Https_Protocol, Messages.FileTransferNamespace_Mailto_Protocol, Messages.FileTransferNamespace_Gopher_Protocol};

 	private static final String URL_HANDLER_PROTOCOL_NAME = "url.handler.protocol"; //$NON-NLS-1$

 	private static final String URLSTREAM_HANDLER_SERVICE_NAME = "org.osgi.service.url.URLStreamHandlerService"; //$NON-NLS-1$

 	// The plug-in ID
 	public static final String PLUGIN_ID = "org.eclipse.ecf.provider.filetransfer"; //$NON-NLS-1$

 	private static final String RETRIEVE_FILETRANSFER_PROTOCOL_FACTORY_EPOINT = PLUGIN_ID + "." //$NON-NLS-1$
 			+ "retrieveFileTransferProtocolFactory"; //$NON-NLS-1$

 	private static final String SEND_FILETRANSFER_PROTOCOL_FACTORY_EPOINT = PLUGIN_ID + "." //$NON-NLS-1$
 			+ "sendFileTransferProtocolFactory"; //$NON-NLS-1$

 	private static final String BROWSE_FILETRANSFER_PROTOCOL_FACTORY_EPOINT = PLUGIN_ID + "." //$NON-NLS-1$
 			+ "browseFileTransferProtocolFactory"; //$NON-NLS-1$

 	// The shared instance
 	private static Activator plugin;

 	private BundleContext context = null;

 	private ServiceRegistration fileTransferServiceRegistration;

 	private ServiceTracker logServiceTracker = null;
 	private ServiceTracker extensionRegistryTracker = null;

 	private Map retrieveFileTransferProtocolMap = null;

 	private Map sendFileTransferProtocolMap = null;

 	private Map browseFileTransferProtocolMap = null;

 	private ServiceTracker adapterManagerTracker = null;

 	private ServiceTracker proxyServiceTracker = null;

 	/**
 	 * The constructor
 	 */
 	public Activator() {
 		//
 	}

 	protected LogService getLogService() {
 		if (logServiceTracker == null) {
 			logServiceTracker = new ServiceTracker(this.context, LogService.class.getName(), null);
 			logServiceTracker.open();
 		}
 		return (LogService) logServiceTracker.getService();
 	}

 	public IProxyService getProxyService() {
 		if (proxyServiceTracker == null) {
 			proxyServiceTracker = new ServiceTracker(this.context, IProxyService.class.getName(), null);
 			proxyServiceTracker.open();
 		}
 		return (IProxyService) proxyServiceTracker.getService();
 	}

 	public void log(IStatus status) {
 		final LogService logService = getLogService();
 		if (logService != null) {
 			logService.log(LogHelper.getLogCode(status), LogHelper.getLogMessage(status), status.getException());
 		}
 	}

 	public Bundle getBundle() {
 		if (context == null)
 			return null;
 		return context.getBundle();
 	}

 	/*
 	 * (non-Javadoc)
 	 *
 	 * @see org.eclipse.core.runtime.Plugins#start(org.osgi.framework.BundleContext)
 	 */
 	public void start(BundleContext ctxt) throws Exception {
 		plugin = this;
 		this.context = ctxt;
 		fileTransferServiceRegistration = ctxt.registerService(IRetrieveFileTransferFactory.class.getName(), new IRetrieveFileTransferFactory() {
 			public IRetrieveFileTransfer newInstance() {
 				return new MultiProtocolRetrieveAdapter();
 			}
 		}, null);
 		// Can't be lazy about this, as schemes need to be registered with
 		// platform
 		loadProtocolHandlers();
 	}

 	/*
 	 * (non-Javadoc)
 	 *
 	 * @see org.eclipse.core.runtime.Plugin#stop(org.osgi.framework.BundleContext)
 	 */
 	public void stop(BundleContext ctxt) throws Exception {
 		plugin = null;
 		this.context = null;
 		if (fileTransferServiceRegistration != null) {
 			fileTransferServiceRegistration.unregister();
 			fileTransferServiceRegistration = null;
 		}
 		if (adapterManagerTracker != null) {
 			adapterManagerTracker.close();
 			adapterManagerTracker = null;
 		}
 		if (proxyServiceTracker != null) {
 			proxyServiceTracker.close();
 			proxyServiceTracker = null;
 		}
 		this.context = null;
 		if (this.retrieveFileTransferProtocolMap != null) {
 			this.retrieveFileTransferProtocolMap.clear();
 			this.retrieveFileTransferProtocolMap = null;
 		}
 		if (this.sendFileTransferProtocolMap != null) {
 			this.sendFileTransferProtocolMap.clear();
 			this.sendFileTransferProtocolMap = null;
 		}
 		if (this.browseFileTransferProtocolMap != null) {
 			this.browseFileTransferProtocolMap.clear();
 			this.browseFileTransferProtocolMap = null;
 		}
 	}

 	/**
 	 * Returns the shared instance
 	 *
 	 * @return the shared instance
 	 */
 	public synchronized static Activator getDefault() {
 		if (plugin == null) {
 			plugin = new Activator();
 		}
 		return plugin;
 	}

 	public String[] getPlatformSupportedSchemes() {
 		final ServiceTracker handlers = new ServiceTracker(context, URLSTREAM_HANDLER_SERVICE_NAME, null);
 		handlers.open();
 		final ServiceReference[] refs = handlers.getServiceReferences();
 		final Set protocols = new HashSet();
 		if (refs != null)
 			for (int i = 0; i < refs.length; i++) {
 				final Object protocol = refs[i].getProperty(URL_HANDLER_PROTOCOL_NAME);
 				if (protocol instanceof String)
 					protocols.add(protocol);
 				else if (protocol instanceof String[]) {
 					final String[] ps = (String[]) protocol;
 					for (int j = 0; j < ps.length; j++)
 						protocols.add(ps[j]);
 				}
 			}
 		handlers.close();
 		for (int i = 0; i < jvmSchemes.length; i++)
 			protocols.add(jvmSchemes[i]);
 		return (String[]) protocols.toArray(new String[] {});
 	}

 	public IExtensionRegistry getExtensionRegistry() {
 		if (extensionRegistryTracker == null) {
 			this.extensionRegistryTracker = new ServiceTracker(context, IExtensionRegistry.class.getName(), null);
 			this.extensionRegistryTracker.open();
 		}
 		return (IExtensionRegistry) extensionRegistryTracker.getService();
 	}

 	// TODO we need to be dynamic here
 	private void loadProtocolHandlers() {
 		this.retrieveFileTransferProtocolMap = new HashMap(3);
 		this.sendFileTransferProtocolMap = new HashMap(3);
 		this.browseFileTransferProtocolMap = new HashMap(3);
 		final IExtensionRegistry reg = getExtensionRegistry();
 		if (reg != null) {
 			String[] existingSchemes = getPlatformSupportedSchemes();
 			final IExtensionPoint retrieveExtensionPoint = reg.getExtensionPoint(RETRIEVE_FILETRANSFER_PROTOCOL_FACTORY_EPOINT);
 			if (retrieveExtensionPoint == null)
 				return;
 			final IConfigurationElement[] retrieveConfigurationElements = retrieveExtensionPoint.getConfigurationElements();
 			for (int i = 0; i < retrieveConfigurationElements.length; i++) {
 				try {
 					final String protocol = retrieveConfigurationElements[i].getAttribute(PROTOCOL_ATTR);
 					if (protocol == null || "".equals(protocol)) //$NON-NLS-1$
 						continue;
 					if (retrieveFileTransferProtocolMap.containsKey(protocol)) {
 						// Give warning
 						Activator.getDefault().log(new Status(IStatus.WARNING, PLUGIN_ID, IStatus.WARNING, NLS.bind(Messages.Activator_WARNING_RETRIEVE_PROTOCOL_CONTRIBUTION_WILL_BE_IGNORED, protocol, retrieveExtensionPoint.getContributor().getName()), null));
 						// And continue
 						continue;
 					}
 					final IRetrieveFileTransferFactory clazz = (IRetrieveFileTransferFactory) retrieveConfigurationElements[i].createExecutableExtension(CLASS_ATTR);
 					if (!isSchemeRegistered(protocol, existingSchemes))
 						registerScheme(protocol);
 					// Finally, put clazz in map with protocol as key
 					retrieveFileTransferProtocolMap.put(protocol, clazz);
 				} catch (final CoreException e) {
 					Activator.getDefault().log(new Status(IStatus.ERROR, PLUGIN_ID, IStatus.ERROR, NLS.bind(Messages.Activator_EXCEPTION_LOADING_EXTENSION_POINT, RETRIEVE_FILETRANSFER_PROTOCOL_FACTORY_EPOINT), e));
 				}
 			}
 			// Now do it with send
 			final IExtensionPoint sendExtensionPoint = reg.getExtensionPoint(SEND_FILETRANSFER_PROTOCOL_FACTORY_EPOINT);
 			if (sendExtensionPoint == null) {
 				return;
 			}
 			final IConfigurationElement[] sendConfigurationElements = sendExtensionPoint.getConfigurationElements();
 			existingSchemes = getPlatformSupportedSchemes();
 			for (int i = 0; i < sendConfigurationElements.length; i++) {
 				try {
 					final String protocol = sendConfigurationElements[i].getAttribute(PROTOCOL_ATTR);
 					if (protocol == null || "".equals(protocol)) //$NON-NLS-1$
 						continue;
 					if (sendFileTransferProtocolMap.containsKey(protocol)) {
 						// Give warning
 						Activator.getDefault().log(new Status(IStatus.WARNING, PLUGIN_ID, IStatus.WARNING, NLS.bind(Messages.Activator_WARNING_SEND_PROTOCOL_CONTRIBUTION_IGNORED, protocol, sendExtensionPoint.getContributor().getName()), null));
 						// And continue
 						continue;
 					}
 					final ISendFileTransferFactory clazz = (ISendFileTransferFactory) sendConfigurationElements[i].createExecutableExtension(CLASS_ATTR);
 					if (!isSchemeRegistered(protocol, existingSchemes))
 						registerScheme(protocol);
 					// Finally, put clazz in map with protocol as key
 					sendFileTransferProtocolMap.put(protocol, clazz);
 				} catch (final CoreException e) {
 					Activator.getDefault().log(new Status(IStatus.ERROR, PLUGIN_ID, IStatus.ERROR, NLS.bind(Messages.Activator_EXCEPTION_LOADING_EXTENSION_POINT, SEND_FILETRANSFER_PROTOCOL_FACTORY_EPOINT), e));
 				}
 			}
 			// Now for browse
 			final IExtensionPoint browseExtensionPoint = reg.getExtensionPoint(BROWSE_FILETRANSFER_PROTOCOL_FACTORY_EPOINT);
 			if (browseExtensionPoint == null) {
 				return;
 			}
 			final IConfigurationElement[] browseConfigurationElements = browseExtensionPoint.getConfigurationElements();
 			existingSchemes = getPlatformSupportedSchemes();
 			for (int i = 0; i < browseConfigurationElements.length; i++) {
 				try {
 					final String protocol = browseConfigurationElements[i].getAttribute(PROTOCOL_ATTR);
 					if (protocol == null || "".equals(protocol)) //$NON-NLS-1$
 						continue;
 					if (browseFileTransferProtocolMap.containsKey(protocol)) {
 						// Give warning
 						Activator.getDefault().log(new Status(IStatus.WARNING, PLUGIN_ID, IStatus.WARNING, NLS.bind(Messages.Activator_WARNING_BROWSE_PROTOCOL_CONTRIBUTION_IGNORED, protocol, browseExtensionPoint.getContributor().getName()), null));
 						// And continue
 						continue;
 					}
 					final IRemoteFileSystemBrowserFactory clazz = (IRemoteFileSystemBrowserFactory) browseConfigurationElements[i].createExecutableExtension(CLASS_ATTR);
 					if (!isSchemeRegistered(protocol, existingSchemes))
 						registerScheme(protocol);
 					// Finally, put clazz in map with protocol as key
 					browseFileTransferProtocolMap.put(protocol, clazz);
 				} catch (final CoreException e) {
 					Activator.getDefault().log(new Status(IStatus.ERROR, PLUGIN_ID, IStatus.ERROR, NLS.bind(Messages.Activator_EXCEPTION_LOADING_EXTENSION_POINT, BROWSE_FILETRANSFER_PROTOCOL_FACTORY_EPOINT), e));
 				}
 			}

 		}
 	}

 	private boolean isSchemeRegistered(String protocol, String[] schemes) {
 		for (int i = 0; i < schemes.length; i++) {
 			if (protocol.equals(schemes[i]))
 				return true;
 		}
 		return false;
 	}

 	class DummyURLStreamHandlerService extends AbstractURLStreamHandlerService {

 		/*
 		 * (non-Javadoc)
 		 *
 		 * @see org.osgi.service.url.AbstractURLStreamHandlerService#openConnection(java.net.URL)
 		 */
 		public URLConnection openConnection(URL u) throws IOException {
 			throw new IOException(NLS.bind(Messages.Activator_EXCEPTION_URLConnection_CANNOT_BE_CREATED, u.toExternalForm()));
 		}

 	}

 	private final DummyURLStreamHandlerService dummyService = new DummyURLStreamHandlerService();

 	private void registerScheme(String protocol) {
 		final Hashtable properties = new Hashtable();
 		properties.put(URLConstants.URL_HANDLER_PROTOCOL, new String[] {protocol});
 		context.registerService(URLStreamHandlerService.class.getName(), dummyService, properties);
 	}

 	public IRetrieveFileTransfer getFileTransfer(String protocol) {
 		final IRetrieveFileTransferFactory factory = (IRetrieveFileTransferFactory) retrieveFileTransferProtocolMap.get(protocol);
 		if (factory != null)
 			return factory.newInstance();
 		return null;
 	}

 	public ISendFileTransfer getSendFileTransfer(String protocol) {
 		final ISendFileTransferFactory factory = (ISendFileTransferFactory) sendFileTransferProtocolMap.get(protocol);
 		if (factory != null)
 			return factory.newInstance();
 		return null;
 	}

 	public IRemoteFileSystemBrowser getBrowseFileTransfer(String protocol) {
 		final IRemoteFileSystemBrowserFactory factory = (IRemoteFileSystemBrowserFactory) browseFileTransferProtocolMap.get(protocol);
 		if (factory != null)
 			return factory.newInstance();
 		return null;
 	}

 	public IAdapterManager getAdapterManager() {
 		// First, try to get the adapter manager via
 		if (adapterManagerTracker == null) {
 			adapterManagerTracker = new ServiceTracker(this.context, IAdapterManager.class.getName(), null);
 			adapterManagerTracker.open();
 		}
 		IAdapterManager adapterManager = (IAdapterManager) adapterManagerTracker.getService();
 		// Then, if the service isn't there, try to get from Platform class via
 		// PlatformHelper class
 		if (adapterManager == null)
 			adapterManager = PlatformHelper.getPlatformAdapterManager();
 		return adapterManager;
 	}

 }
	/****************************************************************************
	* Copyright (c) 2006, 2007 Composent, Inc. and others.
	* All rights reserved. This program and the accompanying materials
	* are made available under the terms of the Eclipse Public License v1.0
	* which accompanies this distribution, and is available at
	* http://www.eclipse.org/legal/epl-v10.html
	*
	* Contributors:
	* Composent, Inc. - initial API and implementation
	*****************************************************************************/
	package org.eclipse.ecf.internal.provider.filetransfer;

	import java.io.IOException;
	import java.net.URL;
	import java.net.URLConnection;
	import java.util.*;
	import org.eclipse.core.net.proxy.IProxyService;
	import org.eclipse.core.runtime.*;
	import org.eclipse.ecf.core.util.LogHelper;
	import org.eclipse.ecf.core.util.PlatformHelper;
	import org.eclipse.ecf.filetransfer.service.*;
	import org.eclipse.ecf.provider.filetransfer.retrieve.MultiProtocolRetrieveAdapter;
	import org.eclipse.osgi.util.NLS;
	import org.osgi.framework.*;
	import org.osgi.service.log.LogService;
	import org.osgi.service.url.*;
	import org.osgi.util.tracker.ServiceTracker;

	/**
	* The activator class controls the plug-in life cycle
	*/
	public class Activator implements BundleActivator {

	private static final String CLASS_ATTR = "class"; //$NON-NLS-1$
	private static final String PROTOCOL_ATTR = "protocol"; //$NON-NLS-1$
	private static final String[] jvmSchemes = new String[] {Messages.FileTransferNamespace_Http_Protocol, Messages.FileTransferNamespace_Ftp_Protocol, Messages.FileTransferNamespace_File_Protocol, Messages.FileTransferNamespace_Jar_Protocol, Messages.FileTransferNamespace_Https_Protocol, Messages.FileTransferNamespace_Mailto_Protocol, Messages.FileTransferNamespace_Gopher_Protocol};

	private static final String URL_HANDLER_PROTOCOL_NAME = "url.handler.protocol"; //$NON-NLS-1$

	private static final String URLSTREAM_HANDLER_SERVICE_NAME = "org.osgi.service.url.URLStreamHandlerService"; //$NON-NLS-1$

	// The plug-in ID
	public static final String PLUGIN_ID = "org.eclipse.ecf.provider.filetransfer"; //$NON-NLS-1$

	private static final String RETRIEVE_FILETRANSFER_PROTOCOL_FACTORY_EPOINT = PLUGIN_ID + "." //$NON-NLS-1$
	+ "retrieveFileTransferProtocolFactory"; //$NON-NLS-1$

	private static final String SEND_FILETRANSFER_PROTOCOL_FACTORY_EPOINT = PLUGIN_ID + "." //$NON-NLS-1$
	+ "sendFileTransferProtocolFactory"; //$NON-NLS-1$

	private static final String BROWSE_FILETRANSFER_PROTOCOL_FACTORY_EPOINT = PLUGIN_ID + "." //$NON-NLS-1$
	+ "browseFileTransferProtocolFactory"; //$NON-NLS-1$

	// The shared instance
	private static Activator plugin;

	private BundleContext context = null;

	private ServiceRegistration fileTransferServiceRegistration;

	private ServiceTracker logServiceTracker = null;
	private ServiceTracker extensionRegistryTracker = null;

	private Map retrieveFileTransferProtocolMap = null;

	private Map sendFileTransferProtocolMap = null;

	private Map browseFileTransferProtocolMap = null;

	private ServiceTracker adapterManagerTracker = null;

	private ServiceTracker proxyServiceTracker = null;

	/**
	* The constructor
	*/
	public Activator() {
	//
	}

	protected LogService getLogService() {
	if (logServiceTracker == null) {
	logServiceTracker = new ServiceTracker(this.context, LogService.class.getName(), null);
	logServiceTracker.open();
	}
	return (LogService) logServiceTracker.getService();
	}

	public IProxyService getProxyService() {
	if (proxyServiceTracker == null) {
	proxyServiceTracker = new ServiceTracker(this.context, IProxyService.class.getName(), null);
	proxyServiceTracker.open();
	}
	return (IProxyService) proxyServiceTracker.getService();
	}

	public void log(IStatus status) {
	final LogService logService = getLogService();
	if (logService != null) {
	logService.log(LogHelper.getLogCode(status), LogHelper.getLogMessage(status), status.getException());
	}
	}

	public Bundle getBundle() {
	if (context == null)
	return null;
	return context.getBundle();
	}

	/*
	* (non-Javadoc)
	*
	* @see org.eclipse.core.runtime.Plugins#start(org.osgi.framework.BundleContext)
	*/
	public void start(BundleContext ctxt) throws Exception {
	plugin = this;
	this.context = ctxt;
	fileTransferServiceRegistration = ctxt.registerService(IRetrieveFileTransferFactory.class.getName(), new IRetrieveFileTransferFactory() {
	public IRetrieveFileTransfer newInstance() {
	return new MultiProtocolRetrieveAdapter();
	}
	}, null);
	// Can't be lazy about this, as schemes need to be registered with
	// platform
	loadProtocolHandlers();
	}

	/*
	* (non-Javadoc)
	*
	* @see org.eclipse.core.runtime.Plugin#stop(org.osgi.framework.BundleContext)
	*/
	public void stop(BundleContext ctxt) throws Exception {
	plugin = null;
	this.context = null;
	if (fileTransferServiceRegistration != null) {
	fileTransferServiceRegistration.unregister();
	fileTransferServiceRegistration = null;
	}
	if (adapterManagerTracker != null) {
	adapterManagerTracker.close();
	adapterManagerTracker = null;
	}
	if (proxyServiceTracker != null) {
	proxyServiceTracker.close();
	proxyServiceTracker = null;
	}
	this.context = null;
	if (this.retrieveFileTransferProtocolMap != null) {
	this.retrieveFileTransferProtocolMap.clear();
	this.retrieveFileTransferProtocolMap = null;
	}
	if (this.sendFileTransferProtocolMap != null) {
	this.sendFileTransferProtocolMap.clear();
	this.sendFileTransferProtocolMap = null;
	}
	if (this.browseFileTransferProtocolMap != null) {
	this.browseFileTransferProtocolMap.clear();
	this.browseFileTransferProtocolMap = null;
	}
	}

	/**
	* Returns the shared instance
	*
	* @return the shared instance
	*/
	public synchronized static Activator getDefault() {
	if (plugin == null) {
	plugin = new Activator();
	}
	return plugin;
	}

	public String[] getPlatformSupportedSchemes() {
	final ServiceTracker handlers = new ServiceTracker(context, URLSTREAM_HANDLER_SERVICE_NAME, null);
	handlers.open();
	final ServiceReference[] refs = handlers.getServiceReferences();
	final Set protocols = new HashSet();
	if (refs != null)
	for (int i = 0; i < refs.length; i++) {
	final Object protocol = refs[i].getProperty(URL_HANDLER_PROTOCOL_NAME);
	if (protocol instanceof String)
	protocols.add(protocol);
	else if (protocol instanceof String[]) {
	final String[] ps = (String[]) protocol;
	for (int j = 0; j < ps.length; j++)
	protocols.add(ps[j]);
	}
	}
	handlers.close();
	for (int i = 0; i < jvmSchemes.length; i++)
	protocols.add(jvmSchemes[i]);
	return (String[]) protocols.toArray(new String[] {});
	}

	public IExtensionRegistry getExtensionRegistry() {
	if (extensionRegistryTracker == null) {
	this.extensionRegistryTracker = new ServiceTracker(context, IExtensionRegistry.class.getName(), null);
	this.extensionRegistryTracker.open();
	}
	return (IExtensionRegistry) extensionRegistryTracker.getService();
	}

	// TODO we need to be dynamic here
	private void loadProtocolHandlers() {
	this.retrieveFileTransferProtocolMap = new HashMap(3);
	this.sendFileTransferProtocolMap = new HashMap(3);
	this.browseFileTransferProtocolMap = new HashMap(3);
	final IExtensionRegistry reg = getExtensionRegistry();
	if (reg != null) {
	String[] existingSchemes = getPlatformSupportedSchemes();
	final IExtensionPoint retrieveExtensionPoint = reg.getExtensionPoint(RETRIEVE_FILETRANSFER_PROTOCOL_FACTORY_EPOINT);
	if (retrieveExtensionPoint == null)
	return;
	final IConfigurationElement[] retrieveConfigurationElements = retrieveExtensionPoint.getConfigurationElements();
	for (int i = 0; i < retrieveConfigurationElements.length; i++) {
	try {
	final String protocol = retrieveConfigurationElements[i].getAttribute(PROTOCOL_ATTR);
	if (protocol == null \|\| "".equals(protocol)) //$NON-NLS-1$
	continue;
	if (retrieveFileTransferProtocolMap.containsKey(protocol)) {
	// Give warning
	Activator.getDefault().log(new Status(IStatus.WARNING, PLUGIN_ID, IStatus.WARNING, NLS.bind(Messages.Activator_WARNING_RETRIEVE_PROTOCOL_CONTRIBUTION_WILL_BE_IGNORED, protocol, retrieveExtensionPoint.getContributor().getName()), null));
	// And continue
	continue;
	}
	final IRetrieveFileTransferFactory clazz = (IRetrieveFileTransferFactory) retrieveConfigurationElements[i].createExecutableExtension(CLASS_ATTR);
	if (!isSchemeRegistered(protocol, existingSchemes))
	registerScheme(protocol);
	// Finally, put clazz in map with protocol as key
	retrieveFileTransferProtocolMap.put(protocol, clazz);
	} catch (final CoreException e) {
	Activator.getDefault().log(new Status(IStatus.ERROR, PLUGIN_ID, IStatus.ERROR, NLS.bind(Messages.Activator_EXCEPTION_LOADING_EXTENSION_POINT, RETRIEVE_FILETRANSFER_PROTOCOL_FACTORY_EPOINT), e));
	}
	}
	// Now do it with send
	final IExtensionPoint sendExtensionPoint = reg.getExtensionPoint(SEND_FILETRANSFER_PROTOCOL_FACTORY_EPOINT);
	if (sendExtensionPoint == null) {
	return;
	}
	final IConfigurationElement[] sendConfigurationElements = sendExtensionPoint.getConfigurationElements();
	existingSchemes = getPlatformSupportedSchemes();
	for (int i = 0; i < sendConfigurationElements.length; i++) {
	try {
	final String protocol = sendConfigurationElements[i].getAttribute(PROTOCOL_ATTR);
	if (protocol == null \|\| "".equals(protocol)) //$NON-NLS-1$
	continue;
	if (sendFileTransferProtocolMap.containsKey(protocol)) {
	// Give warning
	Activator.getDefault().log(new Status(IStatus.WARNING, PLUGIN_ID, IStatus.WARNING, NLS.bind(Messages.Activator_WARNING_SEND_PROTOCOL_CONTRIBUTION_IGNORED, protocol, sendExtensionPoint.getContributor().getName()), null));
	// And continue
	continue;
	}
	final ISendFileTransferFactory clazz = (ISendFileTransferFactory) sendConfigurationElements[i].createExecutableExtension(CLASS_ATTR);
	if (!isSchemeRegistered(protocol, existingSchemes))
	registerScheme(protocol);
	// Finally, put clazz in map with protocol as key
	sendFileTransferProtocolMap.put(protocol, clazz);
	} catch (final CoreException e) {
	Activator.getDefault().log(new Status(IStatus.ERROR, PLUGIN_ID, IStatus.ERROR, NLS.bind(Messages.Activator_EXCEPTION_LOADING_EXTENSION_POINT, SEND_FILETRANSFER_PROTOCOL_FACTORY_EPOINT), e));
	}
	}
	// Now for browse
	final IExtensionPoint browseExtensionPoint = reg.getExtensionPoint(BROWSE_FILETRANSFER_PROTOCOL_FACTORY_EPOINT);
	if (browseExtensionPoint == null) {
	return;
	}
	final IConfigurationElement[] browseConfigurationElements = browseExtensionPoint.getConfigurationElements();
	existingSchemes = getPlatformSupportedSchemes();
	for (int i = 0; i < browseConfigurationElements.length; i++) {
	try {
	final String protocol = browseConfigurationElements[i].getAttribute(PROTOCOL_ATTR);
	if (protocol == null \|\| "".equals(protocol)) //$NON-NLS-1$
	continue;
	if (browseFileTransferProtocolMap.containsKey(protocol)) {
	// Give warning
	Activator.getDefault().log(new Status(IStatus.WARNING, PLUGIN_ID, IStatus.WARNING, NLS.bind(Messages.Activator_WARNING_BROWSE_PROTOCOL_CONTRIBUTION_IGNORED, protocol, browseExtensionPoint.getContributor().getName()), null));
	// And continue
	continue;
	}
	final IRemoteFileSystemBrowserFactory clazz = (IRemoteFileSystemBrowserFactory) browseConfigurationElements[i].createExecutableExtension(CLASS_ATTR);
	if (!isSchemeRegistered(protocol, existingSchemes))
	registerScheme(protocol);
	// Finally, put clazz in map with protocol as key
	browseFileTransferProtocolMap.put(protocol, clazz);
	} catch (final CoreException e) {
	Activator.getDefault().log(new Status(IStatus.ERROR, PLUGIN_ID, IStatus.ERROR, NLS.bind(Messages.Activator_EXCEPTION_LOADING_EXTENSION_POINT, BROWSE_FILETRANSFER_PROTOCOL_FACTORY_EPOINT), e));
	}
	}

	}
	}

	private boolean isSchemeRegistered(String protocol, String[] schemes) {
	for (int i = 0; i < schemes.length; i++) {
	if (protocol.equals(schemes[i]))
	return true;
	}
	return false;
	}

	class DummyURLStreamHandlerService extends AbstractURLStreamHandlerService {

	/*
	* (non-Javadoc)
	*
	* @see org.osgi.service.url.AbstractURLStreamHandlerService#openConnection(java.net.URL)
	*/
	public URLConnection openConnection(URL u) throws IOException {
	throw new IOException(NLS.bind(Messages.Activator_EXCEPTION_URLConnection_CANNOT_BE_CREATED, u.toExternalForm()));
	}

	}

	private final DummyURLStreamHandlerService dummyService = new DummyURLStreamHandlerService();

	private void registerScheme(String protocol) {
	final Hashtable properties = new Hashtable();
	properties.put(URLConstants.URL_HANDLER_PROTOCOL, new String[] {protocol});
	context.registerService(URLStreamHandlerService.class.getName(), dummyService, properties);
	}

	public IRetrieveFileTransfer getFileTransfer(String protocol) {
	final IRetrieveFileTransferFactory factory = (IRetrieveFileTransferFactory) retrieveFileTransferProtocolMap.get(protocol);
	if (factory != null)
	return factory.newInstance();
	return null;
	}

	public ISendFileTransfer getSendFileTransfer(String protocol) {
	final ISendFileTransferFactory factory = (ISendFileTransferFactory) sendFileTransferProtocolMap.get(protocol);
	if (factory != null)
	return factory.newInstance();
	return null;
	}

	public IRemoteFileSystemBrowser getBrowseFileTransfer(String protocol) {
	final IRemoteFileSystemBrowserFactory factory = (IRemoteFileSystemBrowserFactory) browseFileTransferProtocolMap.get(protocol);
	if (factory != null)
	return factory.newInstance();
	return null;
	}

	public IAdapterManager getAdapterManager() {
	// First, try to get the adapter manager via
	if (adapterManagerTracker == null) {
	adapterManagerTracker = new ServiceTracker(this.context, IAdapterManager.class.getName(), null);
	adapterManagerTracker.open();
	}
	IAdapterManager adapterManager = (IAdapterManager) adapterManagerTracker.getService();
	// Then, if the service isn't there, try to get from Platform class via
	// PlatformHelper class
	if (adapterManager == null)
	adapterManager = PlatformHelper.getPlatformAdapterManager();
	return adapterManager;
	}

	}