Examples of org.infinispan.loaders.CacheStore.store()

org.infinispan.loaders.CacheStore.store()
Stores an entry @param entry entry to store @throws CacheLoaderException in the event of problems writing to the store

      c1.store(toEntry("112", "Boston is close to Toronto"));
      c2.store(toEntry("112", "Boston is close to Toronto"));
      c1.store(toEntry("113", "Toronto is a capital of Ontario"));
      c2.store(toEntry("113", "Toronto is a capital of Ontario"));
      c1.store(toEntry("114", "JUDCon is cool"));
      c2.store(toEntry("114", "JUDCon is cool"));
      c1.store(toEntry("211", "JBoss World is awesome"));
      c2.store(toEntry("211", "JBoss World is awesome"));
      c1.store(toEntry("212", "JBoss rules"));
      c2.store(toEntry("212", "JBoss rules"));
      c1.store(toEntry("213", "JBoss division of RedHat "));

View Full Code Here

      c1.store(toEntry("113", "Toronto is a capital of Ontario"));
      c2.store(toEntry("113", "Toronto is a capital of Ontario"));
      c1.store(toEntry("114", "JUDCon is cool"));
      c2.store(toEntry("114", "JUDCon is cool"));
      c1.store(toEntry("211", "JBoss World is awesome"));
      c2.store(toEntry("211", "JBoss World is awesome"));
      c1.store(toEntry("212", "JBoss rules"));
      c2.store(toEntry("212", "JBoss rules"));
      c1.store(toEntry("213", "JBoss division of RedHat "));
      c2.store(toEntry("213", "JBoss division of RedHat "));
      c1.store(toEntry("214", "RedHat community"));

View Full Code Here

      c1.store(toEntry("114", "JUDCon is cool"));
      c2.store(toEntry("114", "JUDCon is cool"));
      c1.store(toEntry("211", "JBoss World is awesome"));
      c2.store(toEntry("211", "JBoss World is awesome"));
      c1.store(toEntry("212", "JBoss rules"));
      c2.store(toEntry("212", "JBoss rules"));
      c1.store(toEntry("213", "JBoss division of RedHat "));
      c2.store(toEntry("213", "JBoss division of RedHat "));
      c1.store(toEntry("214", "RedHat community"));
      c2.store(toEntry("214", "RedHat community"));

View Full Code Here

      c1.store(toEntry("211", "JBoss World is awesome"));
      c2.store(toEntry("211", "JBoss World is awesome"));
      c1.store(toEntry("212", "JBoss rules"));
      c2.store(toEntry("212", "JBoss rules"));
      c1.store(toEntry("213", "JBoss division of RedHat "));
      c2.store(toEntry("213", "JBoss division of RedHat "));
      c1.store(toEntry("214", "RedHat community"));
      c2.store(toEntry("214", "RedHat community"));


      MapReduceTask<String, String, String, Integer> task = createMapReduceTask(cache1);
      task.mappedWith(mapper).reducedWith(reducer);

View Full Code Here

      c1.store(toEntry("212", "JBoss rules"));
      c2.store(toEntry("212", "JBoss rules"));
      c1.store(toEntry("213", "JBoss division of RedHat "));
      c2.store(toEntry("213", "JBoss division of RedHat "));
      c1.store(toEntry("214", "RedHat community"));
      c2.store(toEntry("214", "RedHat community"));


      MapReduceTask<String, String, String, Integer> task = createMapReduceTask(cache1);
      task.mappedWith(mapper).reducedWith(reducer);
      if(useCombiner)
         task.combinedWith(reducer);

View Full Code Here

      final String v1 = "real-data";
      final String v2 = "stale-data";


      // Simulate c3 was by itself and someone wrote a value that is now stale
      CacheStore store = TestingUtil.extractComponent(c3, CacheLoaderManager.class).getCacheStore();
      store.store(TestInternalCacheEntryFactory.create(k, v2));


      c1.put(k, v1);


      assertEquals(v1, c3.get(k));
   }

View Full Code Here

      final String v1 = "real-data";
      final String v2 = "stale-data";


      // Simulate c3 was by itself and someone wrote a value that is now stale
      CacheStore store = TestingUtil.extractComponent(c3, CacheLoaderManager.class).getCacheStore();
      store.store(TestInternalCacheEntryFactory.create(k, v2));


      c1.put(k, v1);


      assertEquals(v1, c3.get(k));
   }

View Full Code Here

      CacheStore c1 = getStore(cache1);
      CacheStore c2 = getStore(cache2);


      //store each entry into each cache store directly
      c1.store(toEntry("1", "Hello world here I am"));
      c2.store(toEntry("1", "Hello world here I am"));
      c1.store(toEntry("2", "Infinispan rules the world"));
      c2.store(toEntry("2", "Infinispan rules the world"));
      c1.store(toEntry("3", "JUDCon is in Boston"));
      c2.store(toEntry("3", "JUDCon is in Boston"));
      c1.store(toEntry("4", "JBoss World is in Boston as well"));

View Full Code Here


      //store each entry into each cache store directly
      c1.store(toEntry("1", "Hello world here I am"));
      c2.store(toEntry("1", "Hello world here I am"));
      c1.store(toEntry("2", "Infinispan rules the world"));
      c2.store(toEntry("2", "Infinispan rules the world"));
      c1.store(toEntry("3", "JUDCon is in Boston"));
      c2.store(toEntry("3", "JUDCon is in Boston"));
      c1.store(toEntry("4", "JBoss World is in Boston as well"));
      c2.store(toEntry("4", "JBoss World is in Boston as well"));
      c1.store(toEntry("12","JBoss Application Server"));

View Full Code Here

      c1.store(toEntry("1", "Hello world here I am"));
      c2.store(toEntry("1", "Hello world here I am"));
      c1.store(toEntry("2", "Infinispan rules the world"));
      c2.store(toEntry("2", "Infinispan rules the world"));
      c1.store(toEntry("3", "JUDCon is in Boston"));
      c2.store(toEntry("3", "JUDCon is in Boston"));
      c1.store(toEntry("4", "JBoss World is in Boston as well"));
      c2.store(toEntry("4", "JBoss World is in Boston as well"));
      c1.store(toEntry("12","JBoss Application Server"));
      c2.store(toEntry("12","JBoss Application Server"));
      c1.store(toEntry("15", "Hello world"));

View Full Code Here

0 1 2 3 4

TOP

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.