Java Code Examples for org.osgi.framework.BundleContext

/** 
 * Post process after initialisation.
 * @param bean the bean
 * @param beanId the bean id
 * @return the object
 * @throws BeansException the beans exception
 */
public Object postProcessAfterInitialization(Object bean,String beanId) throws BeansException {
  List<Class<?>> interfaces=AKIntrospector.getInterfacesAsList(bean);
  if (ignoreBean(bean,beanId,interfaces)) {
    return bean;
  }
  Framework framework=getFramework();
  BundleContext bundleContext=framework.getBundleContext();
  registerService(bundleContext,bean,beanId,interfaces);
  return createProxy(bundleContext,bean,beanId,interfaces);
}
 

private void injectBundleContext(Object testCase,Field field){
  try {
    BundleContext context=getBundleContext();
    log.fine("Injecting bundle context: " + context);
    field.set(testCase,context);
  }
 catch (  IllegalAccessException ex) {
    throw new IllegalStateException("Cannot inject BundleContext",ex);
  }
}
 

private BundleContext getSystemBundleContext(){
  BundleContext bundleContext=bundleContextInst.get();
  if (bundleContext == null)   bundleContext=getBundleContextFromHolder();
  bundleContext=bundleContext.getBundle(0).getBundleContext();
  return bundleContext;
}
 

@Test public void testDoStart() throws Exception {
  BundleContext bundleContext=mock(BundleContext.class);
  OsgiDefaultEndpoint endpoint=mock(OsgiDefaultEndpoint.class);
  when(endpoint.getApplicationBundleContext()).thenReturn(bundleContext);
  Service processor=mock(Service.class,withSettings().extraInterfaces(Processor.class));
  Map<String,Object> props=Collections.singletonMap("key",(Object)"value");
  OsgiDefaultConsumer consumer=new OsgiDefaultConsumer(endpoint,(Processor)processor,props);
  ServiceHelper.startService(consumer);
  verify(processor).start();
  verify(bundleContext).registerService(eq(OsgiComponent.OBJECT_CLASS),same(consumer),eq(new Hashtable<String,Object>(props)));
}
 

@Override public void serviceChanged(ServiceEvent event){
  BundleContext bundleContext=event.getServiceReference().getBundle().getBundleContext();
  LogReaderService logReaderService=(LogReaderService)bundleContext.getService(event.getServiceReference());
  if (logReaderService != null) {
    if (event.getType() == ServiceEvent.REGISTERED) {
      Activator.this.logReaders.add(logReaderService);
      logReaderService.addLogListener(Activator.this.fileLogger);
    }
 else     if (event.getType() == ServiceEvent.UNREGISTERING) {
      logReaderService.removeLogListener(Activator.this.fileLogger);
      Activator.this.logReaders.remove(logReaderService);
    }
  }
}
 

@Test public void testBundleInjection() throws Exception {
  assertNotNull("Bundle injected",bundle);
  assertEquals("Bundle RESOLVED",Bundle.RESOLVED,bundle.getState());
  bundle.start();
  assertEquals("Bundle ACTIVE",Bundle.ACTIVE,bundle.getState());
  BundleContext context=bundle.getBundleContext();
  assertNotNull("BundleContext available",context);
  ServiceReference sref=context.getServiceReference(SimpleService.class.getName());
  assertNotNull("ServiceReference not null",sref);
  SimpleService service=(SimpleService)context.getService(sref);
  assertNotNull("Service not null",service);
  int sum=service.sum(1,2,3);
  assertEquals(6,sum);
  bundle.stop();
  assertEquals("Bundle RESOLVED",Bundle.RESOLVED,bundle.getState());
}
 

public URL createBlueprintModel(Bundle bundle){
  Tblueprint tblueprint=generateBlueprintModel(bundle);
  if (tblueprint != null) {
    BundleContext ctx=getBlueprintExtenderContext();
    if (ctx == null) {
      ctx=bundle.getBundleContext();
    }
    File dir=ctx.getDataFile(bundle.getSymbolicName() + "/" + bundle.getVersion()+ "/");
    if (!dir.exists()) {
      dir.mkdirs();
    }
    String blueprintPath=cachePath(bundle,"annotation-generated-blueprint.xml");
    File file=ctx.getDataFile(blueprintPath);
    if (!file.exists()) {
      try {
        file.createNewFile();
      }
 catch (      IOException e) {
        e.printStackTrace();
      }
    }
    try {
      marshallOBRModel(tblueprint,file);
    }
 catch (    JAXBException e) {
      e.printStackTrace();
    }
    try {
      return file.toURL();
    }
 catch (    MalformedURLException e) {
      e.printStackTrace();
    }
  }
  return null;
}
 

public BuildListeners(){
  IConfigurationElement[] elements=Platform.getExtensionRegistry().getConfigurationElementsFor(Plugin.PLUGIN_ID,"buildListeners");
  listeners=new ArrayList<BuildListener>(elements.length);
  for (  IConfigurationElement elem : elements) {
    try {
      BuildListener listener=(BuildListener)elem.createExecutableExtension("class");
      listeners.add(listener);
    }
 catch (    Exception e) {
      logger.logError("Unable to instantiate build listener: " + elem.getAttribute("name"),e);
    }
  }
  BundleContext context=FrameworkUtil.getBundle(BuildListeners.class).getBundleContext();
  listenerTracker=new ServiceTracker(context,BuildListener.class.getName(),null);
  listenerTracker.open();
}
 

/** 
 * Returns a map containing all managed  {@code EventHandler}s and their status.
 * @param command
 * @return
 */
@Override public ManageHandlersResult execute(ManageHandlersCommand command){
  ManageHandlersResult result=new ManageHandlersResult(command.getId());
  BundleContext bundleContext=((BundleReference)getClass().getClassLoader()).getBundle().getBundleContext();
  ServiceReference[] references=new ServiceReference[0];
  try {
    references=bundleContext.getServiceReferences(EventHandler.class.getName(),EventHandler.MANAGED_FILTER);
    if (references != null && references.length > 0) {
      for (      ServiceReference ref : references) {
        EventHandler handler=(EventHandler)bundleContext.getService(ref);
        if (command.getHandlesName() != null && command.getHandlesName().equals(handler.getClass().getName())) {
          if (command.getStatus()) {
            handler.getSwitch().turnOn();
          }
 else           handler.getSwitch().turnOff();
        }
        result.getHandlers().put(handler.getClass().getName(),handler.getSwitch().getStatus().name());
      }
    }
  }
 catch (  InvalidSyntaxException e) {
    logger.error("Syntax error looking up service {} using filter {}",EventHandler.class.getName(),EventHandler.MANAGED_FILTER);
  }
 finally {
    if (references != null) {
      for (      ServiceReference ref : references) {
        bundleContext.ungetService(ref);
      }
    }
  }
  return result;
}
 

private void retreiveAdminService(){
  ServiceReference[] refs=null;
  BundleContext context=getInstanceManager().getContext();
  try {
    refs=context.getServiceReferences(AdminData.class.getName(),"(chain.name=" + (String)m_dictionary.get(ConstModel.PROPERTY_CHAIN_ID) + ")");
  }
 catch (  InvalidSyntaxException e) {
    logger.warn("Admin data service lookup unrecoverable error");
    refs=null;
  }
  if (refs != null)   m_refData=refs[0];
 else {
    logger.warn("Admin data service not found");
    return;
  }
}
 

/** 
 * Called whenever the OSGi framework starts our bundle
 */
public void start(BundleContext bc) throws Exception {
  HeadsUpLoggerManager.getInstance().setConfiguration(Manager.getStorageInstance().getGlobalConfiguration());
  DefaultManager manager=new DefaultManager();
  manager.load();
  Manager.setInstance(manager);
  tracker=new AppTracker(bc);
  tracker.open();
  services=new ServTracker(bc);
  services.open();
}
 

@Override public void start(BundleContext context) throws Exception {
  Bundle[] allBundles=context.getBundles();
  ArrayList<Bundle> bundleList=new ArrayList<Bundle>();
  for (  Bundle bundle : allBundles) {
    String symbolicName=bundle.getSymbolicName();
    if ((symbolicName.startsWith("com.siemens.ct.osgi.vaadin.pm") || symbolicName.startsWith("al.gov.asp.smc") || symbolicName.startsWith("com.siemens.ct.pm.model.")) && !((symbolicName.contains("main") || symbolicName.contains("theme") || symbolicName.contains("bundleview")|| symbolicName.contains("logback")))) {
      bundleList.add(bundle);
    }
  }
  bundles=bundleList.toArray(new Bundle[]{});
}
 

/** 
 * {@inheritDoc}
 */
public void start(BundleContext context) throws Exception {
  tracker=new ServiceTracker(context,PreferencesService.class.getName(),null);
  tracker.open();
  service=(PreferencesService)tracker.getService();
  Preferences preferences=service.getSystemPreferences();
  preferences.put(COLOR,"lavender");
  System.out.println("My favourite color is: " + preferences.get(COLOR,""));
}
 

@Override public void start(BundleContext context) throws Exception {
  super.start(context);
  plugin=this;
  proxyServiceTracker=new ServiceTracker(context,IProxyService.class.getName(),null);
  proxyServiceTracker.open();
  accountInfoMonitor=new AccountInfoMonitor();
  bootstrapAccountPreferences();
  getPreferenceStore().addPropertyChangeListener(accountInfoMonitor);
}
 

/** 
 * {@inheritDoc}
 */
@Override public void start(BundleContext ctxt) throws Exception {
  super.start(ctxt);
  this.listener=new Listener();
  plugin=this;
  runAsync(new Runnable(){
    @Override public void run(){
      while (workbench == null) {
        yield();
        workbench=getWorkbench();
      }
      IWorkbenchWindow win=workbench.getActiveWorkbenchWindow();
      win=workbench.getActiveWorkbenchWindow();
      ISelectionService selsvc=win.getSelectionService();
      selsvc.addSelectionListener(listener);
      IWorkspace ws=getWorkspace();
      ws.addResourceChangeListener(listener);
    }
  }
);
  IPreferenceStore ps=getPreferenceStore();
  String bfhome=ps.getString(BF_PREF_KEY);
  if (noLength(bfhome)) {
    bfhome=ENV_BELFRAMEWORK_HOME;
  }
  if (validateFramework(bfhome) != FileState.OK) {
  }
 else {
    ps.setValue(BF_PREF_KEY,bfhome);
    reloadResources();
  }
}
 

/** 
 * This method returns one service instance, or <code>null</code> if no service is currently registered.
 * @param bundleContext the  {@link BundleContext} of your plugin. You can obtain aninstance of the  {@link BundleContext} through your Activator.
 * @param clazz The  {@link Class} of the service. Typically an Java Interface
 * @return service instance of the given {@link Class} type, or<code>null</code>
 */
@SuppressWarnings({"rawtypes","unchecked"}) public static <T>T getService(BundleContext bundleContext,Class<T> clazz){
  ServiceReference serviceReference=bundleContext.getServiceReference(clazz.getName());
  if (serviceReference == null) {
    return null;
  }
  Object service=bundleContext.getService(serviceReference);
  if (service == null) {
    return null;
  }
  return (T)service;
}
 

public void start(BundleContext context) throws Exception {
  super.start(context);
  plugin=this;
  manager=new BioPEPAManager();
  colourManager=new ColourManager();
}
 

public void start(BundleContext context) throws Exception {
  super.start(context);
  plugin=this;
  javaFinderTracker=new ServiceTracker(context,IJavaClusteringManager.class.getName(),null);
  javaFinderTracker.open();
  jsFinderTracker=new ServiceTracker(context,IJavaScriptClusteringManager.class.getName(),null);
  jsFinderTracker.open();
}
 

public void start(BundleContext context) throws Exception {
  super.start(context);
  plugin=this;
  javaFinderTracker=new ServiceTracker(context,IJavaOpentoxManager.class.getName(),null);
  javaFinderTracker.open();
  jsFinderTracker=new ServiceTracker(context,IJavaScriptOpentoxManager.class.getName(),null);
  jsFinderTracker.open();
  openToxServices=new ArrayList<OpenToxService>();
  logger.debug("Initializing OpenTox services");
  List<OpenToxService> prefss=ServiceReader.readServicesFromPreferences();
  openToxServices.addAll(prefss);
  logger.debug("Read " + prefss.size() + " services from prefs");
  List<OpenToxService> epservices=ServiceReader.readServicesFromExtensionPoints();
  for (  OpenToxService eps : epservices) {
    if (!openToxServices.contains(eps)) {
      openToxServices.add(eps);
      logger.debug("Added new service from EP: " + eps);
    }
  }
  Preferences preferences=ConfigurationScope.INSTANCE.getNode(OpenToxConstants.PLUGIN_ID);
  List<String[]> toPrefs=ServicesPreferencePage.convertPreferenceStringToArraylist(preferences.get(OpenToxConstants.SERVICES,"n/a"));
  for (  OpenToxService eps : epservices) {
    String[] entry=new String[3];
    entry[0]=eps.getName();
    entry[1]=eps.getService();
    entry[2]=eps.getServiceSPARQL();
    if (!listContains(toPrefs,entry))     toPrefs.add(entry);
  }
  String toPrefsString=ServicesPreferencePage.convertToPreferenceString(toPrefs);
  preferences.put(OpenToxConstants.SERVICES,toPrefsString);
  try {
    preferences.flush();
  }
 catch (  BackingStoreException e) {
    logger.error(e.getMessage());
    e.printStackTrace();
  }
  logger.debug("Saved the serialized services prefs string: " + toPrefsString);
  logger.debug("OpenTox initialization ended");
}
 

public void start(BundleContext context) throws Exception {
  super.start(context);
  plugin=this;
  finderTracker=new ServiceTracker(context,IJavaSenecaManager.class.getName(),null);
  finderTracker.open();
  jsFinderTracker=new ServiceTracker(context,IJavaScriptSenecaManager.class.getName(),null);
  jsFinderTracker.open();
  getJudgeExtensions();
}
 

public void start(BundleContext context) throws Exception {
  super.start(context);
  plugin=this;
  finderTracker=new ServiceTracker(context,IJavaBibtexManager.class.getName(),null);
  finderTracker.open();
  jsFinderTracker=new ServiceTracker(context,IJavaScriptBibtexManager.class.getName(),null);
  jsFinderTracker.open();
}
 

public void start(BundleContext context) throws Exception {
  super.start(context);
  plugin=this;
  javaFinderTracker=new ServiceTracker(context,IJavaVScreenManager.class.getName(),null);
  javaFinderTracker.open();
  jsFinderTracker=new ServiceTracker(context,IJavaScriptVScreenManager.class.getName(),null);
  jsFinderTracker.open();
}
 

public void start(BundleContext bundleContext) throws Exception {
  System.out.println("Register jeditresource URL handler...");
  Dictionary<String,String> properties=new Hashtable<String,String>();
  properties.put(URLConstants.URL_HANDLER_PROTOCOL,"jeditresource");
  bundleContext.registerService(URLStreamHandlerService.class.getName(),new JEditResourceHandlerService(),properties);
  System.out.println("Starting JEdit...");
  jEdit.main(new String[]{"-nobackground","-noserver"});
}
 

public void start(BundleContext context) throws Exception {
  super.start(context);
  plugin=this;
  startClojureCode(context);
  if (System.getProperty("ccw.autostartnrepl") != null) {
    startREPLServer();
  }
  this.natureAdapter.start();
}
 

@Override public void start(BundleContext context) throws Exception {
  String ceylonRepositoryProperty=System.getProperty("ceylon.repo","");
  ceylonRepository=getCeylonPluginRepository(ceylonRepositoryProperty);
  super.start(context);
  this.bundleContext=context;
  addResourceFilterPreference();
  registerProjectOpenCloseListener();
}
 

public void start(BundleContext context) throws Exception {
  super.start(context);
  plugin=this;
  SpecRepoService.getInstance();
  JarRepoService.getInstance();
  AbstractCompositionsRepoService.getInstance();
  DSCiliaRepoService.getInstance();
}