Package org.jboss.cache

Examples of org.jboss.cache.Region.deactivate()

84
85
86
87
88
89
90
91
92
93
94
      // restart c1 so that it forces a state transfer from c2
      c1.destroy();
      c1.create();
      Region r = c1.getRegion(fqn.getParent(), true);
      r.registerContextClassLoader(getClass().getClassLoader());
      r.deactivate();
      c1.start();

      TestingUtil.blockUntilViewsReceived(60000, c1, c2);

      // assert that the state has been transferred to C1
View Full Code Here
67
68
69
70
71
72
73
74
75
76
77
      assertTrue("Should be active by default", region1.isActive());
      // make sure this newly created region is "recognised" as a marshalling region.
      assertTrue(caches.get(1).getRegionManager().getAllRegions(Region.Type.MARSHALLING).contains(region1));

      // now deactivate the region on cache 1.
      region1.deactivate();
      assertFalse("Should be have deactivated", region1.isActive());

      caches.get(0).put(f, "k", "v2");
      assertEquals("v2", caches.get(0).get(f, "k"));
      assertNull(caches.get(1).get(f, "k"));
View Full Code Here
74
75
76
77
78
79
80
81
82
83
84
      r.activate();

      cache.put(rootRegionName, "a key", "a value");
      cache.put(hereFqn, "another key", "another value");

      r.deactivate();
      r.unregisterContextClassLoader();

      cache.stop();

      cache.start();
View Full Code Here
285
286
287
288
289
290
291
292
293
294
295
           
         try {
            Region region = plainCache_.getRegion(pathFqn, false);
            if (region != null)
            {
               region.deactivate();
               region.unregisterContextClassLoader();
            }
         }
         catch (Exception e)
         {
View Full Code Here
110
111
112
113
114
115
116
117
118
119
120
      cache1.getInvocationContext().getOptionOverrides().setCacheModeLocal(true);
      cache1.put(fqn, "name", JOE);

      assertEquals("Put should have been OK", JOE, cache1.get(fqn, "name"));

      regionA.deactivate();

      assertNull("Inactivation should have cleared region", cache1.get(fqn, "name"));
   }

   protected CacheSPI<Object, Object> createCache() throws Exception
View Full Code Here
73
74
75
76
77
78
79
80
81
82
83
      r.activate();

      cache.put(rootRegionName, "a key", "a value");
      cache.put(hereFqn, "another key", "another value");

      r.deactivate();
      r.unregisterContextClassLoader();

      cache.stop();

      cache.start();
View Full Code Here
230
231
232
233
234
235
236
237
238
239
240
         cache2 = createCache("nbst", false);
         cache2.getConfiguration().setUseRegionBasedMarshalling(true);
         region = cache2.getRegion(Fqn.fromString("/region1"), true);
         region.registerContextClassLoader(getClass().getClassLoader());
         cache2.start();
         region.deactivate();

         // Pause to give caches time to see each other
         TestingUtil.blockUntilViewsReceived(new CacheSPI[] { cache1, cache2 }, 60000);

         cache1.put("/region1/blah", "blah", "blah");
View Full Code Here
374
375
376
377
378
379
380
381
382
383
384
            // and enabling the stressors
            for (int i = 0; i < count; i++)
            {
               Region r = cacheA.getRegion(Fqn.fromString("/" + names[i]), true);
               r.registerContextClassLoader(getClass().getClassLoader());
               r.deactivate();
               stressors[i].startPuts();
            }

            // Release the semaphore to allow the threads to start work
            semaphore.release(count);
View Full Code Here
269
270
271
272
273
274
275
276
277
278
279
           
         try {
            Region region = plainCache_.getRegion(pathFqn, false);
            if (region != null)
            {
               region.deactivate();
               region.unregisterContextClassLoader();
            }
         }
         catch (Exception e)
         {
View Full Code Here
290
291
292
293
294
295
296
297
298
299
300
           
         try {
            Region region = plainCache_.getRegion(pathFqn, false);
            if (region != null)
            {
               region.deactivate();
               region.unregisterContextClassLoader();
            }
         }
         catch (Exception e)
         {
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.