X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fconfig%2Fconfig-manager%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fconfig%2Fmanager%2Fimpl%2Fosgi%2FBeanToOsgiServiceManager.java;h=3d93a9df7dee72bb450af215bd7dea97f24199a5;hb=aebe2884329d666f661be53e2de3a57e4fcf61f1;hp=b592fa3c79736d09b22f0b133bef142702783dbb;hpb=ec82a960337ba51c2e896863a668dcf8fbcfcb6b;p=controller.git
diff --git a/opendaylight/config/config-manager/src/main/java/org/opendaylight/controller/config/manager/impl/osgi/BeanToOsgiServiceManager.java b/opendaylight/config/config-manager/src/main/java/org/opendaylight/controller/config/manager/impl/osgi/BeanToOsgiServiceManager.java
index b592fa3c79..3d93a9df7d 100644
--- a/opendaylight/config/config-manager/src/main/java/org/opendaylight/controller/config/manager/impl/osgi/BeanToOsgiServiceManager.java
+++ b/opendaylight/config/config-manager/src/main/java/org/opendaylight/controller/config/manager/impl/osgi/BeanToOsgiServiceManager.java
@@ -8,7 +8,6 @@
package org.opendaylight.controller.config.manager.impl.osgi;
import static com.google.common.base.Preconditions.checkState;
-
import java.util.Dictionary;
import java.util.HashSet;
import java.util.Hashtable;
@@ -49,7 +48,7 @@ public class BeanToOsgiServiceManager {
public static class OsgiRegistration implements AutoCloseable {
- private static final Logger logger = LoggerFactory.getLogger(OsgiRegistration.class);
+ private static final Logger LOG = LoggerFactory.getLogger(OsgiRegistration.class);
@GuardedBy("this")
private AutoCloseable instance;
@@ -72,7 +71,14 @@ public class BeanToOsgiServiceManager {
Map serviceNamesToAnnotations) {
Set> serviceRegistrations = new HashSet<>();
for (Entry entry : serviceNamesToAnnotations.entrySet()) {
- Class> requiredInterface = entry.getKey().osgiRegistrationType();
+ ServiceInterfaceAnnotation annotation = entry.getKey();
+ Class> requiredInterface = annotation.osgiRegistrationType();
+
+ if(!annotation.registerToOsgi()) {
+ LOG.debug("registerToOsgi for service interface {} is false - not registering", requiredInterface);
+ continue;
+ }
+
checkState(requiredInterface.isInstance(instance), instance.getClass().getName() +
" instance should implement " + requiredInterface.getName());
Dictionary propertiesForOsgi = createProps(entry.getValue());
@@ -89,7 +95,7 @@ public class BeanToOsgiServiceManager {
try {
serviceRegistration.unregister();
} catch(IllegalStateException e) {
- logger.trace("Cannot unregister {}", serviceRegistration, e);
+ LOG.trace("Cannot unregister {}", serviceRegistration, e);
}
}
serviceRegistrations.clear();
@@ -101,7 +107,7 @@ public class BeanToOsgiServiceManager {
notEquals |= newAnnotationMapping.equals(serviceNamesToAnnotations) == false;
if (notEquals) {
// FIXME: changing from old state to new state can be improved by computing the diff
- logger.debug("Detected change in service registrations for {}: old: {}, new: {}", moduleIdentifier,
+ LOG.debug("Detected change in service registrations for {}: old: {}, new: {}", moduleIdentifier,
serviceNamesToAnnotations, newAnnotationMapping);
close();
this.instance = newInstance;