in features/src/main/java/org/apache/karaf/cellar/features/internal/osgi/Activator.java [66:137]
public void doStart() throws Exception {
ConfigurationAdmin configurationAdmin = getTrackedService(ConfigurationAdmin.class);
if (configurationAdmin == null)
return;
ClusterManager clusterManager = getTrackedService(ClusterManager.class);
if (clusterManager == null)
return;
GroupManager groupManager = getTrackedService(GroupManager.class);
if (groupManager == null)
return;
EventProducer eventProducer = getTrackedService(EventProducer.class);
if (eventProducer == null)
return;
FeaturesService featuresService = getTrackedService(FeaturesService.class);
if (featuresService == null)
return;
LOGGER.debug("CELLAR FEATURE: init repository event handler");
repositoryEventHandler = new RepositoryEventHandler();
repositoryEventHandler.setConfigurationAdmin(configurationAdmin);
repositoryEventHandler.setFeaturesService(featuresService);
repositoryEventHandler.setClusterManager(clusterManager);
repositoryEventHandler.setGroupManager(groupManager);
repositoryEventHandler.init(bundleContext);
Hashtable props = new Hashtable();
props.put("managed", "true");
register(new Class[]{ EventHandler.class }, repositoryEventHandler, props);
LOGGER.debug("CELLAR FEATURE: init features event handler");
featuresEventHandler = new FeaturesEventHandler();
featuresEventHandler.setFeaturesService(featuresService);
featuresEventHandler.setClusterManager(clusterManager);
featuresEventHandler.setGroupManager(groupManager);
featuresEventHandler.setConfigurationAdmin(configurationAdmin);
featuresEventHandler.init(bundleContext);
register(new Class[]{ EventHandler.class }, featuresEventHandler, props);
LOGGER.debug("CELLAR FEATURE: init local features listener");
localFeaturesListener = new LocalFeaturesListener();
localFeaturesListener.setClusterManager(clusterManager);
localFeaturesListener.setGroupManager(groupManager);
localFeaturesListener.setEventProducer(eventProducer);
localFeaturesListener.setConfigurationAdmin(configurationAdmin);
localFeaturesListener.setFeaturesService(featuresService);
localFeaturesListener.init(bundleContext);
register(FeaturesListener.class, localFeaturesListener);
LOGGER.debug("CELLAR FEATURE: init features synchronizer");
featuresSynchronizer = new FeaturesSynchronizer();
featuresSynchronizer.setClusterManager(clusterManager);
featuresSynchronizer.setGroupManager(groupManager);
featuresSynchronizer.setEventProducer(eventProducer);
featuresSynchronizer.setConfigurationAdmin(configurationAdmin);
featuresSynchronizer.setFeaturesService(featuresService);
featuresSynchronizer.init(bundleContext);
props = new Hashtable();
props.put("resource", "feature");
register(Synchronizer.class, featuresSynchronizer, props);
LOGGER.debug("CELLAR FEATURE: register MBean");
CellarFeaturesMBeanImpl mbean = new CellarFeaturesMBeanImpl();
mbean.setClusterManager(clusterManager);
mbean.setGroupManager(groupManager);
mbean.setConfigurationAdmin(configurationAdmin);
mbean.setFeaturesService(featuresService);
mbean.setEventProducer(eventProducer);
props = new Hashtable();
props.put("jmx.objectname", "org.apache.karaf.cellar:type=feature,name=" + System.getProperty("karaf.name"));
mbeanRegistration = bundleContext.registerService(getInterfaceNames(mbean), mbean, props);
}