import org.opendaylight.controller.clustering.services.IGetUpdates;
import org.opendaylight.controller.clustering.services.IListenRoleChange;
import org.opendaylight.controller.clustering.services.ListenRoleChangeAddException;
-import org.opendaylight.controller.sal.core.IContainerAware;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class ClusterManager implements IClusterServices, IContainerAware {
+public class ClusterManager implements IClusterServices {
protected static final Logger logger = LoggerFactory
.getLogger(ClusterManager.class);
private DefaultCacheManager cm;
try {
ParserRegistry parser = new ParserRegistry(this.getClass()
.getClassLoader());
- ConfigurationBuilderHolder holder = parser.parseFile("config/infinispan-config.xml");
+ String infinispanConfigFile =
+ System.getProperty("org.infinispan.config.file", "config/infinispan-config.xml");
+ logger.debug("Using configuration file:{}", infinispanConfigFile);
+ ConfigurationBuilderHolder holder = parser.parseFile(infinispanConfigFile);
GlobalConfigurationBuilder globalBuilder = holder.getGlobalConfigurationBuilder();
globalBuilder.serialization()
.classResolver(new ClassResolver())
return null;
}
for (String cacheName : manager.getCacheNames()) {
+ if (!manager.isRunning(cacheName)) continue;
if (cacheName.startsWith("{" + containerName + "}_")) {
String[] res = cacheName.split("[{}]");
if (res.length >= 4 && res[1].equals(containerName)
}
}
}
-
- private void removeContainerCaches(String containerName) {
- logger.info("Destroying caches for container {}", containerName);
- for (String cacheName : this.getCacheList(containerName)) {
- this.destroyCache(containerName, cacheName);
- }
- }
-
- @Override
- public void containerCreate(String arg0) {
- // no op
- }
-
- @Override
- public void containerDestroy(String container) {
- removeContainerCaches(container);
- }
}