import org.apache.cxf.management.jmx.InstrumentationManagerImpl; //导入依赖的package包/类
@Bean
public InstrumentationManager instrumentationManager(SpringBus cxf) {
    InstrumentationManagerImpl impl = new InstrumentationManagerImpl();
    impl.setEnabled(true);
    impl.setBus(cxf);
    impl.setUsePlatformMBeanServer(true);
    return impl;
}
 

import org.apache.cxf.management.jmx.InstrumentationManagerImpl; //导入依赖的package包/类
public void destroy(@Observes final AssemblerDestroyed ignored) {
    final SystemInstance systemInstance = SystemInstance.get();
    final Bus bus = getBus();
    if ("true".equalsIgnoreCase(systemInstance.getProperty("openejb.cxf.jmx", "true"))) {
        final InstrumentationManager mgr = bus.getExtension(InstrumentationManager.class);
        if (InstrumentationManagerImpl.class.isInstance(mgr)) {
            mgr.shutdown();
        }
    }
    systemInstance.removeObserver(this);
}
 

import org.apache.cxf.management.jmx.InstrumentationManagerImpl; //导入依赖的package包/类
public static void configureBus() {
    if (USER_COUNT.incrementAndGet() > 1) {
        return;
    }

    final SystemInstance systemInstance = SystemInstance.get();

    final Bus bus = getBus();

    // ensure cxf classes are loaded from container to avoid conflicts with app
    if ("true".equalsIgnoreCase(systemInstance.getProperty("openejb.cxf.CxfContainerClassLoader", "true"))) {
        bus.setExtension(new CxfContainerClassLoader(), ClassLoader.class);
    }

    // activate jmx, by default isEnabled() == false in InstrumentationManagerImpl
    final boolean hasMonitoring = hasMonitoring(systemInstance);
    if (hasMonitoring || "true".equalsIgnoreCase(systemInstance.getProperty("openejb.cxf.jmx", "true"))) {
        final InstrumentationManager mgr = bus.getExtension(InstrumentationManager.class);
        if (InstrumentationManagerImpl.class.isInstance(mgr)) {
            bus.setExtension(LocalMBeanServer.get(), MBeanServer.class); // just to keep everything consistent

            final InstrumentationManagerImpl manager = InstrumentationManagerImpl.class.cast(mgr);
            manager.setEnabled(true);
            manager.setServer(LocalMBeanServer.get());
            manager.setDaemon(true);

            try { // avoid to bother our nice logs
                LogUtils.getL7dLogger(InstrumentationManagerImpl.class).setLevel(Level.WARNING);
            } catch (final Throwable th) {
                // no-op
            }

            // failed when bus was constructed or even if passed we switch the MBeanServer
            manager.init();
        }
    }
    if (hasMonitoring) {
        new CounterRepository().setBus(bus);
    }

    final ServiceConfiguration configuration = new ServiceConfiguration(systemInstance.getProperties(),
            systemInstance.getComponent(OpenEjbConfiguration.class).facilities.services);

    final Collection<ServiceInfo> serviceInfos = configuration.getAvailableServices();
    Properties properties = configuration.getProperties();
    if (properties == null) {
        properties = new Properties();
    }

    final String featuresIds = properties.getProperty(BUS_PREFIX + FEATURES);
    if (featuresIds != null) {
        final List<Feature> features = createFeatures(serviceInfos, featuresIds);
        if (features != null) {
            features.addAll(bus.getFeatures());
            bus.setFeatures(features);
        }
    }

    final Properties busProperties = ServiceInfos.serviceProperties(serviceInfos, properties.getProperty(BUS_PREFIX + ENDPOINT_PROPERTIES));
    if (busProperties != null) {
        bus.getProperties().putAll(PropertiesHelper.map(busProperties));
    }

    configureInterceptors(bus, BUS_PREFIX, serviceInfos, configuration.getProperties());

    systemInstance.getProperties().setProperty(BUS_CONFIGURED_FLAG, "true");
    systemInstance.fireEvent(new BusCreated(bus));
}