[infinispan-commits] Infinispan SVN: r2194 - trunk/tree/src/test/java/org/infinispan/loaders.

[infinispan-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2010-08-11 07:48:49 -0400 (Wed, 11 Aug 2010)
New Revision: 2194

Modified:
   trunk/tree/src/test/java/org/infinispan/loaders/TreeCacheWithLoaderTest.java
Log:
Added test to ensure tree nodes and data are being persisted

Modified: trunk/tree/src/test/java/org/infinispan/loaders/TreeCacheWithLoaderTest.java
===================================================================
--- trunk/tree/src/test/java/org/infinispan/loaders/TreeCacheWithLoaderTest.java	2010-08-11 11:47:02 UTC (rev 2193)
+++ trunk/tree/src/test/java/org/infinispan/loaders/TreeCacheWithLoaderTest.java	2010-08-11 11:48:49 UTC (rev 2194)
@@ -1,5 +1,6 @@
 package org.infinispan.loaders;
 
+import org.infinispan.atomic.AtomicMap;
 import org.infinispan.config.CacheLoaderManagerConfig;
 import org.infinispan.config.Configuration;
 import org.infinispan.loaders.dummy.DummyInMemoryCacheStore;
@@ -39,12 +40,14 @@
       assert "value".equals(cache.get("/a/b/c", "key"));
 
       assert store.containsKey(new NodeKey(Fqn.fromString("/a/b/c"), NodeKey.Type.DATA));
+      assert "value".equals(((AtomicMap) store.load(new NodeKey(Fqn.fromString("/a/b/c"), NodeKey.Type.DATA)).getValue()).get("key"));
       assert store.containsKey(new NodeKey(Fqn.fromString("/a/b/c"), NodeKey.Type.STRUCTURE));
 
       cache.stop();
       cache.start();
       assert "value".equals(cache.get("/a/b/c", "key"));
       assert store.containsKey(new NodeKey(Fqn.fromString("/a/b/c"), NodeKey.Type.DATA));
+      assert "value".equals(((AtomicMap) store.load(new NodeKey(Fqn.fromString("/a/b/c"), NodeKey.Type.DATA)).getValue()).get("key"));
       assert store.containsKey(new NodeKey(Fqn.fromString("/a/b/c"), NodeKey.Type.STRUCTURE));
    }
 
@@ -52,6 +55,7 @@
       cache.put(Fqn.ROOT, "key", "value");
       assert "value".equals(cache.get(Fqn.ROOT, "key"));
       assert store.containsKey(new NodeKey(Fqn.ROOT, NodeKey.Type.DATA));
+      assert "value".equals(((AtomicMap) store.load(new NodeKey(Fqn.ROOT, NodeKey.Type.DATA)).getValue()).get("key"));
       assert store.containsKey(new NodeKey(Fqn.ROOT, NodeKey.Type.STRUCTURE));
 
       cache.stop();
@@ -59,6 +63,7 @@
       assert "value".equals(cache.get(Fqn.ROOT, "key"));
 
       assert store.containsKey(new NodeKey(Fqn.ROOT, NodeKey.Type.DATA));
+      assert "value".equals(((AtomicMap) store.load(new NodeKey(Fqn.ROOT, NodeKey.Type.DATA)).getValue()).get("key"));
       assert store.containsKey(new NodeKey(Fqn.ROOT, NodeKey.Type.STRUCTURE));
    }