001/* 002 * (C) Copyright 2006-2007 Nuxeo SA (http://nuxeo.com/) and others. 003 * 004 * Licensed under the Apache License, Version 2.0 (the "License"); 005 * you may not use this file except in compliance with the License. 006 * You may obtain a copy of the License at 007 * 008 * http://www.apache.org/licenses/LICENSE-2.0 009 * 010 * Unless required by applicable law or agreed to in writing, software 011 * distributed under the License is distributed on an "AS IS" BASIS, 012 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 013 * See the License for the specific language governing permissions and 014 * limitations under the License. 015 * 016 * Contributors: 017 * <a href="mailto:at@nuxeo.com">Anahide Tchertchian</a> 018 * 019 * $Id: IOManagerComponent.java 24959 2007-09-14 13:46:47Z atchertchian $ 020 */ 021 022package org.nuxeo.ecm.platform.io.impl; 023 024import org.apache.commons.logging.Log; 025import org.apache.commons.logging.LogFactory; 026import org.nuxeo.ecm.platform.io.api.IOManager; 027import org.nuxeo.ecm.platform.io.api.IOResourceAdapter; 028import org.nuxeo.ecm.platform.io.descriptors.IOResourceAdapterDescriptor; 029import org.nuxeo.runtime.model.ComponentInstance; 030import org.nuxeo.runtime.model.ComponentName; 031import org.nuxeo.runtime.model.DefaultComponent; 032 033/** 034 * Component registering {@link IOResourceAdapter} instances to an {@link IOManager}. 035 * 036 * @author <a href="mailto:at@nuxeo.com">Anahide Tchertchian</a> 037 */ 038public class IOManagerComponent extends DefaultComponent { 039 040 public static final ComponentName NAME = new ComponentName(IOManagerComponent.class.getName()); 041 042 public static final String ADAPTERS_EP_NAME = "adapters"; 043 044 private static final Log log = LogFactory.getLog(IOManagerComponent.class); 045 046 private final IOManager service; 047 048 public IOManagerComponent() { 049 service = new IOManagerImpl(); 050 } 051 052 public IOManager getIOManager() { 053 return service; 054 } 055 056 @Override 057 public void registerContribution(Object contribution, String extensionPoint, ComponentInstance contributor) { 058 if (extensionPoint.equals(ADAPTERS_EP_NAME)) { 059 IOResourceAdapterDescriptor desc = (IOResourceAdapterDescriptor) contribution; 060 String name = desc.getName(); 061 String className = desc.getClassName(); 062 IOResourceAdapter adapter; 063 try { 064 // Thread context loader is not working in isolated EARs 065 adapter = (IOResourceAdapter) IOManagerComponent.class.getClassLoader() 066 .loadClass(className) 067 .getDeclaredConstructor() 068 .newInstance(); 069 } catch (ReflectiveOperationException e) { 070 log.error("Caught error when instantiating adapter", e); 071 return; 072 } 073 adapter.setProperties(desc.getProperties()); 074 IOResourceAdapter existing = service.getAdapter(name); 075 if (existing != null) { 076 log.warn(String.format("Overriding IO Resource adapter definition %s", name)); 077 service.removeAdapter(name); 078 } 079 service.addAdapter(name, adapter); 080 log.info(String.format("IO resource adapter %s registered", name)); 081 } else { 082 log.error(String.format("Unknown extension point %s, can't register !", extensionPoint)); 083 } 084 } 085 086 @Override 087 public void unregisterContribution(Object contribution, String extensionPoint, ComponentInstance contributor) { 088 if (extensionPoint.equals(ADAPTERS_EP_NAME)) { 089 IOResourceAdapterDescriptor desc = (IOResourceAdapterDescriptor) contribution; 090 service.removeAdapter(desc.getName()); 091 } else { 092 log.error(String.format("Unknown extension point %s, can't unregister !", extensionPoint)); 093 } 094 } 095 096 @Override 097 @SuppressWarnings("unchecked") 098 public <T> T getAdapter(Class<T> adapter) { 099 if (adapter.isAssignableFrom(IOManager.class)) { 100 return (T) service; 101 } 102 return null; 103 } 104 105}