ISPN-6869 Don't try to stop caches in InternalCacheRegistryImpl

infinispan · May 22, 2017 · ef96e81 · ef96e81
1 parent 92eccec
commit ef96e81
Showing 1 changed file with 0 additions and 11 deletions.
diff --git a/core/src/main/java/org/infinispan/registry/impl/InternalCacheRegistryImpl.java b/core/src/main/java/org/infinispan/registry/impl/InternalCacheRegistryImpl.java
@@ -5,14 +5,12 @@
 import java.util.Set;
 import java.util.concurrent.ConcurrentMap;
 
-import org.infinispan.Cache;
 import org.infinispan.commons.util.CollectionFactory;
 import org.infinispan.commons.util.concurrent.ConcurrentHashSet;
 import org.infinispan.configuration.cache.Configuration;
 import org.infinispan.configuration.cache.ConfigurationBuilder;
 import org.infinispan.configuration.global.GlobalConfiguration;
 import org.infinispan.factories.annotations.Inject;
-import org.infinispan.factories.annotations.Stop;
 import org.infinispan.manager.EmbeddedCacheManager;
 import org.infinispan.registry.InternalCacheRegistry;
 import org.infinispan.util.logging.Log;
@@ -35,15 +33,6 @@ public void init(EmbeddedCacheManager cacheManager) {
       this.cacheManager = cacheManager;
    }
 
-   @Stop(priority = 1)
-   public void stop() {
-      internalCaches.keySet().forEach(cacheName -> {
-         Cache<Object, Object> cache = cacheManager.getCache(cacheName, false);
-         if (cache != null)
-            cache.stop();
-      });
-   }
-
    @Override
    public void registerInternalCache(String name, Configuration configuration) {
       registerInternalCache(name, configuration, EnumSet.noneOf(Flag.class));