Package org.infinispan

Examples of org.infinispan.Cache.stop()

465
466
467
468
469
470
471
472
473
474
475
         }
      }

      if (defaultCache != null) {
         unregisterCacheMBean(defaultCache);
         defaultCache.stop();
      }
      globalComponentRegistry.getComponent(CacheManagerJmxRegistration.class).stop();
      globalComponentRegistry.stop();
   }
View Full Code Here
653
654
655
656
657
658
659
660
661
662
663
                     defaultCache = entry.getValue().cache;
                  } else {
                     Cache c = entry.getValue().cache;
                     if (c != null) {
                        unregisterCacheMBean(c);
                        c.stop();
                     }
                  }
               }

               if (defaultCache != null) {
View Full Code Here
267
268
269
270
271
272
273
274
275
276
277
   @Test(expectedExceptions = IllegalStateException.class)
   public void testEnsureProperCacheState() throws Exception {
      ConfigurationBuilder builder = getDefaultClusteredCacheConfig(CacheMode.DIST_SYNC, true);
      EmbeddedCacheManager cacheManager = addClusterEnabledCacheManager(builder);
      Cache cache = cacheManager.getCache();
      cache.stop();

      try {
         MapReduceTask<String, String, String, Integer> task = createMapReduceTask(cache);
      } catch(IllegalStateException ex) {
         assertNotNull(ex.getMessage());
View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
   @Test(expectedExceptions = IllegalStateException.class)
   public void testCacheStopFollowedByGetCache() {
      Cache cache = cacheManager.getCache();
      cache.put("k", "v");
      cache.stop();
      Cache cache2 = cacheManager.getCache();
      cache2.put("k", "v2");
   }

   @Test(expectedExceptions = IllegalStateException.class)
View Full Code Here
56
57
58
59
60
61
62
63
64
65
   @Test(expectedExceptions = IllegalStateException.class)
   public void testCacheStopFollowedByCacheOp() {
      Cache cache = cacheManager.getCache("big");
      cache.put("k", "v");
      cache.stop();
      cache.put("k", "v2");
   }

}
View Full Code Here
311
312
313
314
315
316
317
318
319
320
321
            assertInCacheAndStore(preloadingCache, preloadingStore, "k" + i, "v" + i, lifespan);
      }

      DataContainer c = preloadingCache.getAdvancedCache().getDataContainer();
      assert c.size() == 4;
      preloadingCache.stop();
      assert c.size() == 0;

      preloadingCache.start();
      // The old store's marshaller is not working any more
      preloadingStore = TestingUtil.extractComponent(preloadingCache, CacheLoaderManager.class).getCacheStore();
View Full Code Here
354
355
356
357
358
359
360
361
362
363
364
            assertInCacheAndStore(purgingCache, purgingStore, "k" + i, "v" + i, lifespan);
      }

      DataContainer c = purgingCache.getAdvancedCache().getDataContainer();
      assert c.size() == 4;
      purgingCache.stop();
      assert c.size() == 0;

      purgingCache.start();
      c = purgingCache.getAdvancedCache().getDataContainer();
      assert c.size() == 0;
View Full Code Here
108
109
110
111
112
113
114
115
116
117
118
               return null;
            }
         };
         callStoppingCacheFuture = executorService.submit(callStoppingCache);
      }
      cache.stop(); // now stop the cache
      latch.countDown(); // now that cache has been stopped, let the thread continue

      log.debug("All threads finished, let's shutdown the executor and check whether any exceptions were reported");
      waitAfterModFuture.get();
      if (callStoppingCacheFuture != null) {
View Full Code Here
237
238
239
240
241
242
243
244
245
246
247
      ) {
         @Override
         public void call() {
            try {
               Cache cache = cm.getCache();
               cache.stop();

               MapReduceTask<String, String, String, Integer> task = createMapReduceTask(cache);
            } catch(IllegalStateException ex) {
               assertNotNull(ex.getMessage());
               assertTrue(ex.getMessage().contains("Cache is in an invalid state:"));
View Full Code Here
652
653
654
655
656
657
658
659
660
661
662
                     defaultCache = entry.getValue().cache;
                  } else {
                     Cache c = entry.getValue().cache;
                     if (c != null) {
                        unregisterCacheMBean(c);
                        c.stop();
                     }
                  }
               }

               if (defaultCache != null) {
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.