Examples of org.jboss.cache.loader.CacheLoader

org.jboss.cache.loader.CacheLoader
A {@link org.jboss.cache.loader.CacheLoader} implementation persists and load keys to and fromsecondary storage, such as a database or filesystem. Typically, implementations store a series of keys and values (an entire {@link Map}) under a single {@link Fqn}. Loading and saving properties of an entire {@link Map} should be atomic.
Lifecycle: First an instance of the loader is created, then the configuration ( {@link #setConfig(org.jboss.cache.config.CacheLoaderConfig.IndividualCacheLoaderConfig)}) and cache ( {@link #setCache(CacheSPI)}) are set. After this, {@link #create()} is called.Then {@link #start()} is called. When re-deployed, {@link #stop()} will becalled, followed by another {@link #start()}. Finally, when shut down, {@link #destroy()} is called, after which the loader is unusable.
An {@link org.jboss.cache.loader.AbstractCacheLoader} is provided as a convenient starting placewhen implementing your own {@link org.jboss.cache.loader.CacheLoader}.
It is important to note that all implementations are thread safe, as concurrent reads and writes, potentially even to the same {@link Fqn}, are possible.
@author Manik Surtani (manik AT jboss DOT org) @see CacheSPI @see org.jboss.cache.config.CacheLoaderConfig.IndividualCacheLoaderConfig @see org.jboss.cache.loader.AbstractCacheLoader @since 2.0.0

   }


   public void testCacheLoadingWithReplication() throws Exception
   {
      CacheSPI<Object, Object> cache1 = createReplicatedCacheWithLoader(false);
      CacheLoader loader1 = cache1.getCacheLoaderManager().getCacheLoader();


      CacheSPI<Object, Object> cache2 = createReplicatedCacheWithLoader(false);
      CacheLoader loader2 = cache2.getCacheLoaderManager().getCacheLoader();


      // test the cache ...
      TransactionManager mgr = cache1.getTransactionManager();
      assertNull(mgr.getTransaction());


      mgr.begin();


      // add something in cache1
      cache1.put(fqn, key, value);
      assertEquals(value, cache1.get(fqn, key));


      // test that loader1, loader2, cache2 doesnt have entry
      assertNull(loader1.get(fqn));
      assertNull(loader2.get(fqn));
      assertNull(cache2.get(fqn, key));


      // commit
      mgr.commit();


      // test that loader1, loader2, cache2 has entry
      assertEquals(value, cache1.get(fqn, key));
      assertEquals(value, loader1.get(fqn).get(key));
      assertEquals(value, loader2.get(fqn).get(key));
      assertEquals(value, cache2.get(fqn, key));


      // cache2 removes entry
      cache2.getTransactionManager().begin();
      cache2.removeNode(fqn);
      assertNull(cache2.get(fqn, key));
      // test that loader1, loader2 and cache2 have the entry
      assertEquals(value, cache1.get(fqn, key));
      assertEquals(value, loader1.get(fqn).get(key));
      assertEquals(value, loader2.get(fqn).get(key));


      // commit
      cache2.getTransactionManager().commit();


      // test that the entry has been removed everywhere.
      assertNull(cache1.getNode(fqn));
      assertNull(loader1.get(fqn));
      assertNull(loader2.get(fqn));
      assertNull(cache2.getNode(fqn));


   }

View Full Code Here

      CacheSPI<Object, Object> cache2 = createCache(false, true, true);


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


      CacheLoader loader = cache2.getCacheLoaderManager().getCacheLoader();


      assertNull("/a/b transferred to loader against policy", loader.get(A_B));


      assertNull("/a/b name transferred against policy", cache2.get(A_B, "name"));
      assertNull("/a/b age transferred against policy", cache2.get(A_B, "age"));
      assertNull("/a/c name transferred against policy", cache2.get(A_C, "name"));
      assertNull("/a/c age transferred against policy", cache2.get(A_C, "age"));


      createAndActivateRegion(cache2, Fqn.ROOT);


      assertEquals("Incorrect name from loader for /a/b", JOE, loader.get(A_B).get("name"));
      assertEquals("Incorrect age from loader for /a/b", TWENTY, loader.get(A_B).get("age"));
      assertEquals("Incorrect name from loader for /a/c", BOB, loader.get(A_C).get("name"));
      assertEquals("Incorrect age from loader for /a/c", FORTY, loader.get(A_C).get("age"));


      assertEquals("Incorrect name for /a/b", JOE, cache2.get(A_B, "name"));
      assertEquals("Incorrect age for /a/b", TWENTY, cache2.get(A_B, "age"));
      assertEquals("Incorrect name for /a/c", BOB, cache2.get(A_C, "name"));
      assertEquals("Incorrect age for /a/c", FORTY, cache2.get(A_C, "age"));

View Full Code Here

   }


   public void testSharedCacheLoadingWithReplication() throws Exception
   {
      CacheSPI<Object, Object> cache1 = createReplicatedCacheWithLoader(true);
      CacheLoader loader1 = cache1.getCacheLoaderManager().getCacheLoader();


      CacheSPI<Object, Object> cache2 = createReplicatedCacheWithLoader(true);
      CacheLoader loader2 = cache2.getCacheLoaderManager().getCacheLoader();


      // test the cache ...
      TransactionManager mgr = cache1.getTransactionManager();
      assertNull(mgr.getTransaction());


      mgr.begin();


      // add something in cache1
      cache1.put(fqn, key, value);
      assertEquals(value, cache1.get(fqn, key));


      // test that loader1, loader2, cache2 doesnt have entry
      assertNull(loader1.get(fqn));
      assertNull(loader2.get(fqn));
      assertNull(cache2.get(fqn, key));


      // commit
      mgr.commit();


      // test that loader1, loader2, cache2 has entry
      assertEquals(value, cache1.get(fqn, key));
      assertEquals(value, loader1.get(fqn).get(key));
      assertEquals(value, loader2.get(fqn).get(key));
      assertEquals(value, cache2.get(fqn, key));


      // cache2 removes entry
      cache2.getTransactionManager().begin();
      cache2.removeNode(fqn);
      assertNull(cache2.get(fqn, key));
      // test that loader1, loader2 and cache2 have the entry
      assertEquals(value, cache1.get(fqn, key));
      assertEquals(value, loader1.get(fqn).get(key));
      assertEquals(value, loader2.get(fqn).get(key));


      // commit
      cache2.getTransactionManager().commit();


      // test that the entry has been removed everywhere.
      assertNull(cache1.getNode(fqn));
      assertNull(loader1.get(fqn));
      assertNull(loader2.get(fqn));
      assertNull(cache2.getNode(fqn));


   }

View Full Code Here

      CacheSPI<Object, Object> cache2 = createCache(false, true, true);


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


      CacheLoader loader = cache2.getCacheLoaderManager().getCacheLoader();


      assertNull("/a/b transferred to loader against policy", loader.get(A_B));


      assertNull("/a/b name transferred against policy", cache2.get(A_B, "name"));
      assertNull("/a/b age transferred against policy", cache2.get(A_B, "age"));
      assertNull("/a/c name transferred against policy", cache2.get(A_C, "name"));
      assertNull("/a/c age transferred against policy", cache2.get(A_C, "age"));


      createAndActivateRegion(cache2, A_B);


      assertEquals("Incorrect name from loader for /a/b", JOE, loader.get(A_B).get("name"));
      assertEquals("Incorrect age from loader for /a/b", TWENTY, loader.get(A_B).get("age"));
      assertNull("/a/c transferred to loader against policy", loader.get(A_C));


      assertEquals("Incorrect name for /a/b", JOE, cache2.get(A_B, "name"));
      assertEquals("Incorrect age for /a/b", TWENTY, cache2.get(A_B, "age"));
      assertNull("/a/c name transferred against policy", cache2.get(A_C, "name"));
      assertNull("/a/c age transferred against policy", cache2.get(A_C, "age"));


      cache1.put(A_D, "name", JANE);


      assertNull("/a/d name transferred against policy", cache2.get(A_D, "name"));


      createAndActivateRegion(cache2, A_C);


      assertEquals("Incorrect name from loader for /a/b", JOE, loader.get(A_B).get("name"));
      assertEquals("Incorrect age from loader for /a/b", TWENTY, loader.get(A_B).get("age"));
      assertEquals("Incorrect name from loader for /a/c", BOB, loader.get(A_C).get("name"));
      assertEquals("Incorrect age from loader for /a/c", FORTY, loader.get(A_C).get("age"));


      assertEquals("Incorrect name for /a/b", JOE, cache2.get(A_B, "name"));
      assertEquals("Incorrect age for /a/b", TWENTY, cache2.get(A_B, "age"));
      assertEquals("Incorrect name for /a/c", BOB, cache2.get(A_C, "name"));
      assertEquals("Incorrect age for /a/c", FORTY, cache2.get(A_C, "age"));
      assertNull("/a/d name transferred against policy", cache2.get(A_D, "name"));


      createAndActivateRegion(cache2, A_D);


      assertEquals("Incorrect name from loader for /a/b", JOE, loader.get(A_B).get("name"));
      assertEquals("Incorrect age from loader for /a/b", TWENTY, loader.get(A_B).get("age"));
      assertEquals("Incorrect name from loader for /a/c", BOB, loader.get(A_C).get("name"));
      assertEquals("Incorrect age from loader for /a/c", FORTY, loader.get(A_C).get("age"));
      assertEquals("Incorrect name from loader for /a/d", JANE, loader.get(A_D).get("name"));


      assertEquals("Incorrect name for /a/b", JOE, cache2.get(A_B, "name"));
      assertEquals("Incorrect age for /a/b", TWENTY, cache2.get(A_B, "age"));
      assertEquals("Incorrect name for /a/c", BOB, cache2.get(A_C, "name"));
      assertEquals("Incorrect age for /a/c", FORTY, cache2.get(A_C, "age"));
      assertEquals("Incorrect name for /a/d", JANE, cache2.get(A_D, "name"));


      cache1.getRegion(A, false).deactivate();


      createAndActivateRegion(cache1, A_B);
      createAndActivateRegion(cache1, A_C);
      createAndActivateRegion(cache1, A_D);


      loader = cache1.getCacheLoaderManager().getCacheLoader();


      assertEquals("Incorrect name from loader for /a/b", JOE, loader.get(A_B).get("name"));
      assertEquals("Incorrect age from loader for /a/b", TWENTY, loader.get(A_B).get("age"));
      assertEquals("Incorrect name from loader for /a/c", BOB, loader.get(A_C).get("name"));
      assertEquals("Incorrect age from loader for /a/c", FORTY, loader.get(A_C).get("age"));
      assertEquals("Incorrect name from loader for /a/d", JANE, loader.get(A_D).get("name"));


      assertEquals("Incorrect name for /a/b", JOE, cache1.get(A_B, "name"));
      assertEquals("Incorrect age for /a/b", TWENTY, cache1.get(A_B, "age"));
      assertEquals("Incorrect name for /a/c", BOB, cache1.get(A_C, "name"));
      assertEquals("Incorrect age for /a/c", FORTY, cache1.get(A_C, "age"));

View Full Code Here

            false, true, true);// start


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


      CacheLoader loader = cache2.getCacheLoaderManager().getCacheLoader();


      assertNull("/a/b not transferred to loader", loader.get(A_B));


      assertNull("/a/b not transferred to cache", cache2.get(A_B, "person"));


      ClassLoader cl2 = getClassLoader();


      //      cache2.registerClassLoader(A, cl2);
      Region r = cache2.getRegion(A, true);
      r.registerContextClassLoader(cl2);


      r.activate();


      assertEquals("Correct state from loader for /a/b", ben.toString(), getUnmarshalled(loader.get(A_B).get("person")).toString());


      assertEquals("Correct state from cache for /a/b", ben.toString(), getUnmarshalled(cache2.get(A_B, "person")).toString());


   }

View Full Code Here

   {
      CacheSPI c1 = createCache(true, false, true, true);
      c1.put(A, "K", "V");


      assert c1.get(A, "K").equals("V");
      CacheLoader l1 = c1.getCacheLoaderManager().getCacheLoader();
      assert l1 != null;


      assert l1.exists(A);
      assert l1.get(A).get("K").equals("V");


      // test persistence
      c1.stop();


      assert l1.exists(A);
      assert l1.get(A).get("K").equals("V");


      Cache c2 = createCache(true, false, true, true);


      c2.put(B, "K", "V");

View Full Code Here

      cache.evict(A_D);
   }


   protected void verifyInitialDataOnLoader(CacheSPI<Object, Object> c) throws Exception
   {
      CacheLoader l = TestingUtil.getCacheLoader(c);
      assertEquals("Incorrect name for /a/b on loader", JOE, l.get(A_B).get("name"));
      assertEquals("Incorrect age for /a/b on loader", TWENTY, l.get(A_B).get("age"));
      assertEquals("Incorrect name for /a/c on loader", BOB, l.get(A_C).get("name"));
      assertEquals("Incorrect age for /a/c on loader", FORTY, l.get(A_C).get("age"));
   }

View Full Code Here

      assert c.getRoot().getChildrenNames().isEmpty(): "Cache should be empty!";
   }


   protected void verifyNoDataOnLoader(CacheSPI<Object, Object> c) throws Exception
   {
      CacheLoader l = TestingUtil.getCacheLoader(c);
      assertNull("Node /a/b should not exist on loader", l.get(A_B));
      assertNull("Node /a/c should not exist on loader", l.get(A_C));
      assertNull("Node /a/d should not exist on loader", l.get(A_D));
   }

View Full Code Here

            }


            CacheLoaderManager clm = c.getCacheLoaderManager();
            if (clm != null)
            {
               CacheLoader cl = c.getCacheLoaderManager().getCacheLoader();
               try
               {
                  if (cl != null) cl.remove(Fqn.ROOT);
               }
               catch (Exception e)
               {
                  // unable to clean cache loader
                  e.printStackTrace();

View Full Code Here

                     // don't care
                  }
               }


               CacheLoaderManager clm = spi.getCacheLoaderManager();
               CacheLoader cl = clm == null ? null : clm.getCacheLoader();
               if (cl != null)
               {
                  try
                  {
                     cl.remove(Fqn.ROOT);
                  }
                  catch (Throwable t)
                  {
                     // don't care
                  }

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of org.jboss.cache.loader.CacheLoader

org.exoplatform.services.jcr.impl.core.lock.jbosscache.CacheableLockManagerImpl

org.jboss.cache.aop.statetransfer.StateTransferAopTestBase

org.jboss.cache.buddyreplication.BuddyReplicationTestsBase

org.jboss.cache.integration.websession.BuddyReplicationFailoverTest

org.jboss.cache.integration.websession.util.BuddyReplicationAssertions

org.jboss.cache.interceptors.CacheLoaderInterceptor

org.jboss.cache.jmx.deprecated.NotificationTest

org.jboss.cache.jmx.NotificationTest

org.jboss.cache.mgmt.CacheLoaderTest

org.jboss.cache.mgmt.NotificationTest

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.