X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=opendaylight%2Fmd-sal%2Fclustered-data-store%2Fimplementation%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fdatastore%2Finternal%2FActivator.java;fp=opendaylight%2Fmd-sal%2Fclustered-data-store%2Fimplementation%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fdatastore%2Finternal%2FActivator.java;h=c94355d4f6b2597964d16a1ef5f64b293878c229;hb=615bd465f9582fc62aa435381197dd92fb6d4069;hp=101da7ffa3474d95c4bc7a66797d172e913e4324;hpb=0726878defbfbf7246e93b3c5bbef5eabd11076e;p=controller.git diff --git a/opendaylight/md-sal/clustered-data-store/implementation/src/main/java/org/opendaylight/controller/datastore/internal/Activator.java b/opendaylight/md-sal/clustered-data-store/implementation/src/main/java/org/opendaylight/controller/datastore/internal/Activator.java index 101da7ffa3..c94355d4f6 100644 --- a/opendaylight/md-sal/clustered-data-store/implementation/src/main/java/org/opendaylight/controller/datastore/internal/Activator.java +++ b/opendaylight/md-sal/clustered-data-store/implementation/src/main/java/org/opendaylight/controller/datastore/internal/Activator.java @@ -9,14 +9,46 @@ package org.opendaylight.controller.datastore.internal; +import org.apache.felix.dm.Component; +import org.opendaylight.controller.clustering.services.IClusterGlobalServices; +import org.opendaylight.controller.datastore.ClusteredDataStore; import org.opendaylight.controller.sal.core.ComponentActivatorAbstractBase; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import java.util.Dictionary; +import java.util.Hashtable; +import java.util.Set; + public class Activator extends ComponentActivatorAbstractBase { protected static final Logger logger = LoggerFactory .getLogger(Activator.class); + @Override + protected Object[] getGlobalImplementations(){ + logger.debug("Calling getGlobalImplementations to return:", ClusteredDataStoreManager.class); + return new Object[] { + ClusteredDataStoreManager.class + }; + } + + + @Override + protected void configureGlobalInstance(Component c, Object imp){ + if (imp.equals(ClusteredDataStoreManager.class)) { + Dictionary> props = new Hashtable>(); + + c.setInterface(new String[] { ClusteredDataStore.class.getName() }, props); + logger.debug("configureGlobalInstance adding dependency:", IClusterGlobalServices.class); + + c.add(createServiceDependency().setService( + IClusterGlobalServices.class).setCallbacks( + "setClusterGlobalServices", + "unsetClusterGlobalServices").setRequired(true)); + + } + } + }