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