[17/21] added repository tests to other cache implementations

[ss...@apache.org]

http://git-wip-us.apache.org/repos/asf/marmotta/blob/d04230ab/libraries/kiwi/kiwi-triplestore/src/test/java/org/apache/marmotta/kiwi/test/cluster/BaseClusterTest.java
----------------------------------------------------------------------
diff --git a/libraries/kiwi/kiwi-triplestore/src/test/java/org/apache/marmotta/kiwi/test/cluster/BaseClusterTest.java b/libraries/kiwi/kiwi-triplestore/src/test/java/org/apache/marmotta/kiwi/test/cluster/BaseClusterTest.java
index d2e12ef..d5f7e16 100644
--- a/libraries/kiwi/kiwi-triplestore/src/test/java/org/apache/marmotta/kiwi/test/cluster/BaseClusterTest.java
+++ b/libraries/kiwi/kiwi-triplestore/src/test/java/org/apache/marmotta/kiwi/test/cluster/BaseClusterTest.java
@@ -20,6 +20,8 @@ package org.apache.marmotta.kiwi.test.cluster;
 import org.apache.marmotta.kiwi.caching.CacheManager;
 import org.apache.marmotta.kiwi.config.CacheManagerType;
 import org.apache.marmotta.kiwi.config.KiWiConfiguration;
+import org.apache.marmotta.kiwi.model.rdf.KiWiAnonResource;
+import org.apache.marmotta.kiwi.model.rdf.KiWiUriResource;
 import org.apache.marmotta.kiwi.persistence.h2.H2Dialect;
 import org.apache.marmotta.kiwi.sail.KiWiStore;
 import org.junit.AfterClass;
@@ -59,11 +61,11 @@ public abstract class BaseClusterTest {
 
 
     @Test
-    public void testClusteredCacheSync() throws InterruptedException, RepositoryException {
+    public void testClusteredCacheUri() throws InterruptedException, RepositoryException {
 
         log.info("testing cache synchronization ...");
 
-        URI u = repositorySync1.getValueFactory().createURI("http://localhost/test1");
+        KiWiUriResource u = (KiWiUriResource) repositorySync1.getValueFactory().createURI("http://localhost/test1");
 
 
         // give the cluster some time to performance asynchronous balancing
@@ -71,18 +73,49 @@ public abstract class BaseClusterTest {
 
 
         log.debug("test if resource is in cache where it was created ...");
-        URI u1 = (URI) cacheManagerSync1.getUriCache().get("http://localhost/test1");
+        KiWiUriResource u1 = cacheManagerSync1.getUriCache().get("http://localhost/test1");
+
+        Assert.assertNotNull(u1);
+        Assert.assertEquals(u, u1);
+        Assert.assertEquals(u.getId(), u1.getId());
+
+        log.debug("test if resource has been synced to other cache in cluster ...");
+        KiWiUriResource u2 = cacheManagerSync2.getUriCache().get("http://localhost/test1");
+
+        Assert.assertNotNull(u2);
+        Assert.assertEquals(u, u2);
+        Assert.assertEquals(u.getId(), u2.getId());
+    }
+
+
+    @Test
+    public void testClusteredCacheBNode() throws InterruptedException, RepositoryException {
+
+        log.info("testing cache synchronization ...");
+
+        KiWiAnonResource u = (KiWiAnonResource) repositorySync1.getValueFactory().createBNode();
+
+
+        // give the cluster some time to performance asynchronous balancing
+        Thread.sleep(100);
+
+
+        log.debug("test if resource is in cache where it was created ...");
+        KiWiAnonResource u1 = cacheManagerSync1.getBNodeCache().get(u.getID());
 
         Assert.assertNotNull(u1);
         Assert.assertEquals(u,u1);
+        Assert.assertEquals(u.getId(), u1.getId());
 
         log.debug("test if resource has been synced to other cache in cluster ...");
-        URI u2 = (URI) cacheManagerSync2.getUriCache().get("http://localhost/test1");
+        KiWiAnonResource u2 = cacheManagerSync2.getBNodeCache().get(u.getID());
 
         Assert.assertNotNull(u2);
-        Assert.assertEquals(u,u2);
+        Assert.assertEquals(u, u2);
+        Assert.assertEquals(u.getId(), u2.getId());
     }
 
+
     @Test
     public void testDisjointClusters() throws InterruptedException, RepositoryException {