* @author Thomas Pantelis
*/
abstract class AbstractDependentComponentFactoryMetadata implements DependentComponentFactoryMetadata {
- private final Logger log = LoggerFactory.getLogger(getClass());
+ final Logger log = LoggerFactory.getLogger(getClass());
private final String id;
private final AtomicBoolean started = new AtomicBoolean();
private final AtomicBoolean satisfied = new AtomicBoolean();
private volatile SatisfactionCallback satisfactionCallback;
private volatile String failureMessage;
private volatile Throwable failureCause;
- private volatile String dependendencyDesc;
+ private volatile String dependencyDesc;
@GuardedBy("serviceRecipes")
private boolean stoppedServiceRecipes;
- protected AbstractDependentComponentFactoryMetadata(String id) {
+ protected AbstractDependentComponentFactoryMetadata(final String id) {
this.id = Preconditions.checkNotNull(id);
}
@Override
public String getDependencyDescriptor() {
- return dependendencyDesc;
+ return dependencyDesc;
}
@Override
return satisfied.get();
}
- protected void setFailureMessage(String failureMessage) {
+ protected void setFailureMessage(final String failureMessage) {
setFailure(failureMessage, null);
}
- protected void setFailure(String failureMessage, Throwable failureCause) {
+ protected void setFailure(final String failureMessage, final Throwable failureCause) {
this.failureMessage = failureMessage;
this.failureCause = failureCause;
}
- protected void setDependendencyDesc(String dependendencyDesc) {
- this.dependendencyDesc = dependendencyDesc;
+ protected void setDependencyDesc(final String dependencyDesc) {
+ this.dependencyDesc = dependencyDesc;
}
protected final ExtendedBlueprintContainer container() {
}
}
- protected void retrieveService(String name, Class<?> interfaceClass, Consumer<Object> onServiceRetrieved) {
+ protected void retrieveService(final String name, final Class<?> interfaceClass,
+ final Consumer<Object> onServiceRetrieved) {
retrieveService(name, interfaceClass.getName(), onServiceRetrieved);
}
- protected void retrieveService(String name, String interfaceName, Consumer<Object> onServiceRetrieved) {
+ protected void retrieveService(final String name, final String interfaceName,
+ final Consumer<Object> onServiceRetrieved) {
synchronized (serviceRecipes) {
if (stoppedServiceRecipes) {
return;
StaticServiceReferenceRecipe recipe = new StaticServiceReferenceRecipe(getId() + "-" + name,
container, interfaceName);
- setDependendencyDesc(recipe.getOsgiFilter());
+ setDependencyDesc(recipe.getOsgiFilter());
serviceRecipes.add(recipe);
recipe.startTracking(onServiceRetrieved);
}
@Override
- public void init(ExtendedBlueprintContainer newContainer) {
+ public void init(final ExtendedBlueprintContainer newContainer) {
this.container = newContainer;
log.debug("{}: In init", logName());
}
@Override
- public void destroy(Object instance) {
+ public void destroy(final Object instance) {
log.debug("{}: In destroy", logName());
stopServiceRecipes();
@SuppressWarnings("unchecked")
@Nullable
- protected <T> T getOSGiService(Class<T> serviceInterface) {
+ protected <T> T getOSGiService(final Class<T> serviceInterface) {
try {
ServiceReference<T> serviceReference =
container().getBundleContext().getServiceReference(serviceInterface);