001/* 002 * (C) Copyright 2006-2017 Nuxeo (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 * matic 018 */ 019package org.nuxeo.ecm.core.management; 020 021import org.nuxeo.ecm.core.event.EventStats; 022import org.nuxeo.ecm.core.management.api.AdministrativeStatusManager; 023import org.nuxeo.ecm.core.management.api.GlobalAdministrativeStatusManager; 024import org.nuxeo.ecm.core.management.api.ProbeManager; 025import org.nuxeo.ecm.core.management.events.EventStatsHolder; 026import org.nuxeo.ecm.core.management.events.EventStatsImpl; 027import org.nuxeo.ecm.core.management.probes.ProbeDescriptor; 028import org.nuxeo.ecm.core.management.probes.ProbeManagerImpl; 029import org.nuxeo.ecm.core.management.statuses.AdministrableServiceDescriptor; 030import org.nuxeo.ecm.core.management.statuses.AdministrativeStatusManagerImpl; 031import org.nuxeo.ecm.core.management.statuses.GlobalAdministrativeStatusManagerImpl; 032import org.nuxeo.ecm.core.management.storage.DocumentStoreConfigurationDescriptor; 033import org.nuxeo.ecm.core.management.storage.DocumentStoreHandlerDescriptor; 034import org.nuxeo.ecm.core.management.storage.DocumentStoreManager; 035import org.nuxeo.runtime.model.ComponentContext; 036import org.nuxeo.runtime.model.ComponentInstance; 037import org.nuxeo.runtime.model.ComponentName; 038import org.nuxeo.runtime.model.DefaultComponent; 039 040/** 041 * @author Stephane Lacoin (Nuxeo EP Software Engineer) 042 */ 043public class CoreManagementComponent extends DefaultComponent { 044 045 public static final ComponentName NAME = new ComponentName(CoreManagementComponent.class.getCanonicalName()); 046 047 public static final String PROBES_EP = "probes"; 048 049 public static final String SERVICE_DEF_EP = "serviceDefinition"; 050 051 public static final String STORAGE_HANDLERS_EP = "storageHandlers"; 052 053 public static final String STORAGE_CONFIG_EP = "storageConfiguration"; 054 055 protected static CoreManagementComponent defaultComponent; 056 057 protected final GlobalAdministrativeStatusManager globalManager = new GlobalAdministrativeStatusManagerImpl(); 058 059 protected final EventStats eventStats = new EventStatsImpl(); 060 061 protected final ProbeManagerImpl probeRunner = new ProbeManagerImpl(); 062 063 protected final DocumentStoreManager storageManager = new DocumentStoreManager(); 064 065 public CoreManagementComponent() { 066 super(); // enables breaking 067 } 068 069 public AdministrativeStatusManagerImpl getLocalManager() { 070 return (AdministrativeStatusManagerImpl) globalManager.getStatusManager( 071 globalManager.getLocalNuxeoInstanceIdentifier()); 072 } 073 074 @Override 075 public <T> T getAdapter(Class<T> adapter) { 076 if (adapter == EventStats.class) { 077 return adapter.cast(eventStats); 078 } 079 if (adapter.isAssignableFrom(GlobalAdministrativeStatusManager.class)) { 080 return adapter.cast(globalManager); 081 } 082 if (adapter.isAssignableFrom(AdministrativeStatusManager.class)) { 083 return adapter.cast(getLocalManager()); 084 } 085 if (adapter.isAssignableFrom(ProbeManager.class)) { 086 return adapter.cast(probeRunner); 087 } 088 return super.getAdapter(adapter); 089 } 090 091 @Override 092 public void registerContribution(Object contribution, String extensionPoint, ComponentInstance contributor) { 093 if (extensionPoint.equals(PROBES_EP)) { 094 probeRunner.registerProbe((ProbeDescriptor) contribution); 095 } else if (extensionPoint.equals(SERVICE_DEF_EP)) { 096 globalManager.registerService((AdministrableServiceDescriptor) contribution); 097 } else if (extensionPoint.equals(STORAGE_HANDLERS_EP)) { 098 storageManager.registerHandler((DocumentStoreHandlerDescriptor) contribution); 099 } else if (extensionPoint.equals(STORAGE_CONFIG_EP)) { 100 storageManager.registerConfig((DocumentStoreConfigurationDescriptor) contribution); 101 } else { 102 super.registerContribution(contribution, extensionPoint, contributor); 103 } 104 } 105 106 @Override 107 public void unregisterContribution(Object contribution, String extensionPoint, ComponentInstance contributor) { 108 if (extensionPoint.equals("probes")) { 109 probeRunner.unregisterProbe((ProbeDescriptor) contribution); 110 } 111 } 112 113 public static CoreManagementComponent getDefault() { 114 return defaultComponent; 115 } 116 117 @Override 118 public void activate(ComponentContext context) { 119 defaultComponent = this; 120 storageManager.install(); 121 EventStatsHolder.clearStats(); 122 } 123 124 @Override 125 public void deactivate(ComponentContext context) { 126 defaultComponent = null; 127 storageManager.uninstall(); 128 EventStatsHolder.clearStats(); 129 } 130 131 @Override 132 public void stop(ComponentContext context) { 133 getLocalManager().onNuxeoServerShutdown(); 134 } 135 136 public void onNuxeoServerStartup() { 137 getLocalManager().onNuxeoServerStartup(); 138 } 139 140}