org.eclipse.gemini.blueprint.service.dependency.internal

Class DefaultMandatoryDependencyManager

java.lang.Object

org.eclipse.gemini.blueprint.service.dependency.internal.DefaultMandatoryDependencyManager

All Implemented Interfaces:

MandatoryServiceDependencyManager, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.DisposableBean

public class DefaultMandatoryDependencyManager
extends java.lang.Object
implements MandatoryServiceDependencyManager, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.DisposableBean

Default implementation of MandatoryServiceDependencyManager which determines the relationship between importers and exporters and unpublishes exported service if they dependent, transitively, on imported OSGi services that are mandatory and cannot be satisfied. Note: aimed for singleton beans only

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	DefaultMandatoryDependencyManager.ImporterDependencyListener Importer state listener that gets associated with each exporter.

Field Summary

Fields

Modifier and Type	Field and Description
private org.springframework.beans.factory.config.ConfigurableListableBeanFactory	beanFactory owning bean factory
private java.util.Map<java.lang.Object,ImporterStateListener>	exporterListener exporter -> importer listener map
private java.util.concurrent.ConcurrentMap<java.lang.String,java.lang.Object>	exportersSeen cache map - useful for avoiding double registration
private java.util.Map<java.lang.Object,java.util.Map<java.lang.Object,java.lang.Boolean>>	exporterToImporterDeps Importers on which an exporter depends.
private java.util.Map<java.lang.Object,java.lang.String>	exporterToName exporter name map
private java.util.concurrent.ConcurrentMap<java.lang.Object,java.lang.String>	importerToName importer -> name map
private static org.apache.commons.logging.Log	log
private static java.lang.Object	VALUE

Constructor Summary

Constructors

Constructor and Description
DefaultMandatoryDependencyManager()

Method Summary

Modifier and Type	Method and Description
private void	addListener(java.lang.Object importer, ImporterStateListener stateListener)
void	addServiceExporter(java.lang.Object exporter, java.lang.String exporterBeanName)
private void	callUnregisterOnStartup(java.lang.Object exporter)
private boolean	checkIfExporterShouldStart(java.lang.Object exporter, java.util.Map<java.lang.Object,java.lang.Boolean> importers)
void	destroy()
protected void	discoverDependentImporterFor(java.lang.String exporterBeanName, java.lang.Object exporter) Discover all the importers for the given exporter.
private boolean	isMandatory(java.lang.Object importer)
private boolean	isSatisfied(java.lang.Object importer)
private void	removeListener(java.lang.Object importer, ImporterStateListener stateListener)
void	removeServiceExporter(java.lang.Object bean, java.lang.String beanName)
void	setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
private void	startExporter(java.lang.Object exporter)
private void	stopExporter(java.lang.Object exporter)

Methods inherited from class java.lang.Object

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

Field Detail

log

private static final org.apache.commons.logging.Log log

exportersSeen

private final java.util.concurrent.ConcurrentMap<java.lang.String,java.lang.Object> exportersSeen

cache map - useful for avoiding double registration

VALUE

private static final java.lang.Object VALUE

exporterToImporterDeps

private final java.util.Map<java.lang.Object,java.util.Map<java.lang.Object,java.lang.Boolean>> exporterToImporterDeps

Importers on which an exporter depends. The exporter instance is used as a key, while the value is represented by a list of importers name and their status (up or down).

exporterListener

private final java.util.Map<java.lang.Object,ImporterStateListener> exporterListener

exporter -> importer listener map

importerToName

private final java.util.concurrent.ConcurrentMap<java.lang.Object,java.lang.String> importerToName

importer -> name map

exporterToName

private final java.util.Map<java.lang.Object,java.lang.String> exporterToName

exporter name map

beanFactory

private org.springframework.beans.factory.config.ConfigurableListableBeanFactory beanFactory

owning bean factory

Constructor Detail

DefaultMandatoryDependencyManager

public DefaultMandatoryDependencyManager()

Method Detail

addServiceExporter

public void addServiceExporter(java.lang.Object exporter,
                               java.lang.String exporterBeanName)

Specified by:

addServiceExporter in interface MandatoryServiceDependencyManager

discoverDependentImporterFor

protected void discoverDependentImporterFor(java.lang.String exporterBeanName,
                                            java.lang.Object exporter)

Discover all the importers for the given exporter. Since the importers are already created before the exporter instance is created, this method only does filtering based on the mandatory imports.

checkIfExporterShouldStart

private boolean checkIfExporterShouldStart(java.lang.Object exporter,
                                           java.util.Map<java.lang.Object,java.lang.Boolean> importers)

removeServiceExporter

public void removeServiceExporter(java.lang.Object bean,
                                  java.lang.String beanName)

Specified by:

removeServiceExporter in interface MandatoryServiceDependencyManager

setBeanFactory

public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
                    throws org.springframework.beans.BeansException

Specified by:

setBeanFactory in interface org.springframework.beans.factory.BeanFactoryAware

Throws:

org.springframework.beans.BeansException

destroy

public void destroy()

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

startExporter

private void startExporter(java.lang.Object exporter)

stopExporter

private void stopExporter(java.lang.Object exporter)

callUnregisterOnStartup

private void callUnregisterOnStartup(java.lang.Object exporter)

addListener

private void addListener(java.lang.Object importer,
                         ImporterStateListener stateListener)

removeListener

private void removeListener(java.lang.Object importer,
                            ImporterStateListener stateListener)

isSatisfied

private boolean isSatisfied(java.lang.Object importer)

isMandatory

private boolean isMandatory(java.lang.Object importer)