org.apache.felix.scr.impl

Class AbstractExtender

java.lang.Object

org.apache.felix.scr.impl.AbstractExtender

All Implemented Interfaces:

java.util.EventListener, org.osgi.framework.BundleActivator, org.osgi.framework.BundleListener, org.osgi.framework.SynchronousBundleListener, org.osgi.util.tracker.BundleTrackerCustomizer<org.osgi.framework.Bundle>

Direct Known Subclasses:

Activator

public abstract class AbstractExtender
extends java.lang.Object
implements org.osgi.framework.BundleActivator, org.osgi.util.tracker.BundleTrackerCustomizer<org.osgi.framework.Bundle>, org.osgi.framework.SynchronousBundleListener

Base class to write bundle extenders. This extender tracks started bundles (or starting if they have a lazy activation policy) and will create an extension for each of them to manage it. The extender will handle all concurrency and synchronization issues. The extender guarantee that all extensions will be stopped synchronously with the STOPPING event of a given bundle and that all extensions will be stopped before the extender bundle is stopped.

Field Summary

Fields

Modifier and Type	Field and Description
private org.osgi.framework.BundleContext	context
private java.util.concurrent.ConcurrentMap<org.osgi.framework.Bundle,java.util.concurrent.FutureTask<java.lang.Void>>	destroying
private java.util.concurrent.ConcurrentMap<org.osgi.framework.Bundle,Activator.ScrExtension>	extensions
private boolean	stopped
private boolean	stopping
private org.osgi.util.tracker.BundleTracker<org.osgi.framework.Bundle>	tracker

Constructor Summary

Constructors

Constructor and Description
AbstractExtender()

Method Summary

Modifier and Type	Method and Description
org.osgi.framework.Bundle	addingBundle(org.osgi.framework.Bundle bundle, org.osgi.framework.BundleEvent event)
void	bundleChanged(org.osgi.framework.BundleEvent event)
protected java.util.Collection<org.osgi.framework.Bundle>	chooseBundlesToDestroy(java.util.Set<org.osgi.framework.Bundle> bundles)
protected java.util.concurrent.ExecutorService	createExecutor() Create the executor used to start extensions asynchronously.
private void	createExtension(org.osgi.framework.Bundle bundle)
protected abstract void	debug(org.osgi.framework.Bundle bundle, java.lang.String msg)
private void	destroyExtension(org.osgi.framework.Bundle bundle)
protected abstract Activator.ScrExtension	doCreateExtension(org.osgi.framework.Bundle bundle) Create the extension for the given bundle, or null if the bundle is not to be extended.
protected void	doStart()
protected void	doStop()
org.osgi.framework.BundleContext	getBundleContext()
boolean	isStopping()
void	modifiedBundle(org.osgi.framework.Bundle bundle, org.osgi.framework.BundleEvent event, org.osgi.framework.Bundle object)
void	removedBundle(org.osgi.framework.Bundle bundle, org.osgi.framework.BundleEvent event, org.osgi.framework.Bundle object)
void	start(org.osgi.framework.BundleContext context)
protected void	startTracking()
void	stop(org.osgi.framework.BundleContext context)
protected void	stopTracking()
protected abstract void	warn(org.osgi.framework.Bundle bundle, java.lang.String msg, java.lang.Throwable t)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

extensions

private final java.util.concurrent.ConcurrentMap<org.osgi.framework.Bundle,Activator.ScrExtension> extensions

destroying

private final java.util.concurrent.ConcurrentMap<org.osgi.framework.Bundle,java.util.concurrent.FutureTask<java.lang.Void>> destroying

stopping

private volatile boolean stopping

stopped

private volatile boolean stopped

context

private org.osgi.framework.BundleContext context

tracker

private org.osgi.util.tracker.BundleTracker<org.osgi.framework.Bundle> tracker

Constructor Detail

AbstractExtender

public AbstractExtender()

Method Detail

getBundleContext

public org.osgi.framework.BundleContext getBundleContext()

isStopping

public boolean isStopping()

start

public void start(org.osgi.framework.BundleContext context)
           throws java.lang.Exception

Specified by:

start in interface org.osgi.framework.BundleActivator

Throws:

java.lang.Exception

stop

public void stop(org.osgi.framework.BundleContext context)
          throws java.lang.Exception

Specified by:

stop in interface org.osgi.framework.BundleActivator

Throws:

java.lang.Exception

doStart

protected void doStart()
                throws java.lang.Exception

Throws:

java.lang.Exception

doStop

protected void doStop()
               throws java.lang.Exception

Throws:

java.lang.Exception

startTracking

protected void startTracking()

stopTracking

protected void stopTracking()

createExecutor

protected java.util.concurrent.ExecutorService createExecutor()

Create the executor used to start extensions asynchronously.

Returns:

an

chooseBundlesToDestroy

protected java.util.Collection<org.osgi.framework.Bundle> chooseBundlesToDestroy(java.util.Set<org.osgi.framework.Bundle> bundles)

bundleChanged

public void bundleChanged(org.osgi.framework.BundleEvent event)

Specified by:

bundleChanged in interface org.osgi.framework.BundleListener

addingBundle

public org.osgi.framework.Bundle addingBundle(org.osgi.framework.Bundle bundle,
                                              org.osgi.framework.BundleEvent event)

Specified by:

addingBundle in interface org.osgi.util.tracker.BundleTrackerCustomizer<org.osgi.framework.Bundle>

modifiedBundle

public void modifiedBundle(org.osgi.framework.Bundle bundle,
                           org.osgi.framework.BundleEvent event,
                           org.osgi.framework.Bundle object)

Specified by:

modifiedBundle in interface org.osgi.util.tracker.BundleTrackerCustomizer<org.osgi.framework.Bundle>

removedBundle

public void removedBundle(org.osgi.framework.Bundle bundle,
                          org.osgi.framework.BundleEvent event,
                          org.osgi.framework.Bundle object)

Specified by:

removedBundle in interface org.osgi.util.tracker.BundleTrackerCustomizer<org.osgi.framework.Bundle>

createExtension

private void createExtension(org.osgi.framework.Bundle bundle)

destroyExtension

private void destroyExtension(org.osgi.framework.Bundle bundle)

doCreateExtension

protected abstract Activator.ScrExtension doCreateExtension(org.osgi.framework.Bundle bundle)
                                                     throws java.lang.Exception

Create the extension for the given bundle, or null if the bundle is not to be extended.

Parameters:

bundle - the bundle to extend

Returns:

The extension

Throws:

java.lang.Exception - If something goes wrong

debug

protected abstract void debug(org.osgi.framework.Bundle bundle,
                              java.lang.String msg)

warn

protected abstract void warn(org.osgi.framework.Bundle bundle,
                             java.lang.String msg,
                             java.lang.Throwable t)