- public void postProcessBeanFactory(
- ConfigurableListableBeanFactory beanFactory) throws BeansException {
- if (!(beanFactory instanceof BeanDefinitionRegistry)) {
- throw new SlcException("Can only work on "
- + BeanDefinitionRegistry.class);
- }
-
- long begin = System.currentTimeMillis();
-
- // Merge all beans implementing these interfaces
- Set<String> beanNames = new HashSet<String>();
- for (Class clss : interfaces) {
- String[] strs = beanFactory.getBeanNamesForType(clss, true, false);
- beanNames.addAll(Arrays.asList(strs));
- }
-
- // Register service factory beans for them
- for (String beanName : beanNames) {
- MutablePropertyValues mpv = new MutablePropertyValues();
- mpv.addPropertyValue("interfaces", interfaces.toArray());
- mpv.addPropertyValue("targetBeanName", beanName);
- if (useServiceProviderContextClassLoader)
- mpv.addPropertyValue("contextClassLoader",
- ExportContextClassLoader.SERVICE_PROVIDER);
- RootBeanDefinition bd = new RootBeanDefinition(
- osgiServiceFactoryClass, mpv);
-
- String exporterBeanName = "osgiService." + beanName;
- if (log.isTraceEnabled())
- log.debug("Registering OSGi service exporter "
- + exporterBeanName);
- ((BeanDefinitionRegistry) beanFactory).registerBeanDefinition(
- exporterBeanName, bd);
+ private BundleContext bundleContext = null;
+
+ // private Class osgiServiceFactoryClass = OsgiServiceFactoryBean.class;
+ // private Boolean useServiceProviderContextClassLoader = false;
+
+ public void onApplicationEvent(ApplicationEvent event) {
+ Map<String, Object> beans = new HashMap<String, Object>();
+ if (event instanceof ContextRefreshedEvent) {
+ if (bundleContext != null) {
+ for (Class clss : interfaces) {
+ ApplicationContext ac = ((ContextRefreshedEvent) event)
+ .getApplicationContext();
+ beans.putAll(ac.getBeansOfType(clss, false, false));
+ }
+
+ int count = 0;
+ for (String beanName : beans.keySet()) {
+ Object bean = beans.get(beanName);
+ List<String> classes = new ArrayList<String>();
+ for (Class clss : interfaces) {
+ if (clss.isAssignableFrom(bean.getClass())) {
+ classes.add(clss.getName());
+ }
+ }
+ Properties props = new Properties();
+ Bundle bundle = bundleContext.getBundle();
+ props.put(Constants.BUNDLE_SYMBOLICNAME,
+ bundle.getSymbolicName());
+ props.put(Constants.BUNDLE_VERSION, bundle.getVersion());
+ // retrocompatibility with pre-1.0:
+ props.put("org.springframework.osgi.bean.name", beanName);
+ bundleContext.registerService(
+ classes.toArray(new String[classes.size()]), bean,
+ props);
+ count++;
+ }
+ if (log.isTraceEnabled())
+ log.trace("Published " + count + " " + interfaces
+ + " as OSGi services from bundle "
+ + bundleContext.getBundle().getSymbolicName() + " "
+ + bundleContext.getBundle().getVersion());
+ // note: the services will be automatically unregistered when
+ // the bundle will be stopped
+ }