Package org.infinispan

Examples of org.infinispan.Cache.stop()


        factories.clear();

        for (Iterator it = caches.iterator(); it.hasNext(); ) {
            try {
                Cache cache = (Cache) it.next();
                cache.stop();
            }
            catch (Exception e) {
                storeException(e);
            }
            finally {
View Full Code Here


      }
    }

    if (defaultCache != null) {
      unregisterCacheMBean(defaultCache);
      defaultCache.stop();
    }
    globalComponentRegistry.getComponent(CacheManagerJmxRegistration.class).stop();
    globalComponentRegistry.stop();
  }
View Full Code Here

                     defaultCache = entry.getValue().cache;
                  } else {
                     Cache c = entry.getValue().cache;
                     if (c != null) {
                        unregisterCacheMBean(c);
                        c.stop();
                     }
                  }
               }

               if (defaultCache != null) {
View Full Code Here

         }
      }

      if (defaultCache != null) {
         unregisterCacheMBean(defaultCache);
         defaultCache.stop();
      }
      globalComponentRegistry.getComponent(CacheManagerJmxRegistration.class).stop();
      globalComponentRegistry.stop();
   }
View Full Code Here

                     defaultCache = entry.getValue().cache;
                  } else {
                     Cache c = entry.getValue().cache;
                     if (c != null) {
                        unregisterCacheMBean(c);
                        c.stop();
                     }
                  }
               }

               if (defaultCache != null) {
View Full Code Here

            defaultCache = entry.getValue().cache;
         } else {
            Cache c = entry.getValue().cache;
            if (c != null) {
               unregisterCacheMBean(c);
               c.stop();
            }
         }
      }

      if (defaultCache != null) {
View Full Code Here

   public void testCacheStopTwice() {
      EmbeddedCacheManager localCacheManager = createLocalCacheManager(false);
      try {
         Cache cache = localCacheManager.getCache();
         cache.put("k", "v");
         cache.stop();
         cache.stop();
      } finally {
         TestingUtil.killCacheManagers(localCacheManager);
      }
   }
View Full Code Here

      EmbeddedCacheManager localCacheManager = createLocalCacheManager(false);
      try {
         Cache cache = localCacheManager.getCache();
         cache.put("k", "v");
         cache.stop();
         cache.stop();
      } finally {
         TestingUtil.killCacheManagers(localCacheManager);
      }
   }
View Full Code Here

   public void testCacheStopManagerStopFollowedByGetCache() {
      EmbeddedCacheManager localCacheManager = createLocalCacheManager(false);
      try {
         Cache cache = localCacheManager.getCache();
         cache.put("k", "v");
         cache.stop();
         localCacheManager.stop();
         localCacheManager.getCache();
      } finally {
         TestingUtil.killCacheManagers(localCacheManager);
      }
View Full Code Here

   public void testCacheStopManagerStopFollowedByCacheOp() {
      EmbeddedCacheManager localCacheManager = createLocalCacheManager(false);
      try {
         Cache cache = localCacheManager.getCache();
         cache.put("k", "v");
         cache.stop();
         localCacheManager.stop();
         cache.put("k", "v2");
      } finally {
         TestingUtil.killCacheManagers(localCacheManager);
      }
View Full Code Here

TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.