You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@marmotta.apache.org by ss...@apache.org on 2014/03/05 13:24:30 UTC
[15/21] git commit: test for remote cache working
test for remote cache working
Project: http://git-wip-us.apache.org/repos/asf/marmotta/repo
Commit: http://git-wip-us.apache.org/repos/asf/marmotta/commit/d46c684b
Tree: http://git-wip-us.apache.org/repos/asf/marmotta/tree/d46c684b
Diff: http://git-wip-us.apache.org/repos/asf/marmotta/diff/d46c684b
Branch: refs/heads/MARMOTTA-450
Commit: d46c684b8a39d15ef597973f89042ba181cad894
Parents: 1497768
Author: Sebastian Schaffert <ss...@apache.org>
Authored: Tue Mar 4 20:39:19 2014 +0100
Committer: Sebastian Schaffert <ss...@apache.org>
Committed: Tue Mar 4 20:39:19 2014 +0100
----------------------------------------------------------------------
.../marmotta/kiwi/test/RemoteClusterTest.java | 26 +++++++++-----------
1 file changed, 12 insertions(+), 14 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/marmotta/blob/d46c684b/libraries/kiwi/kiwi-caching-infinispan/src/test/java/org/apache/marmotta/kiwi/test/RemoteClusterTest.java
----------------------------------------------------------------------
diff --git a/libraries/kiwi/kiwi-caching-infinispan/src/test/java/org/apache/marmotta/kiwi/test/RemoteClusterTest.java b/libraries/kiwi/kiwi-caching-infinispan/src/test/java/org/apache/marmotta/kiwi/test/RemoteClusterTest.java
index 630f64e..4295c28 100644
--- a/libraries/kiwi/kiwi-caching-infinispan/src/test/java/org/apache/marmotta/kiwi/test/RemoteClusterTest.java
+++ b/libraries/kiwi/kiwi-caching-infinispan/src/test/java/org/apache/marmotta/kiwi/test/RemoteClusterTest.java
@@ -17,7 +17,6 @@
package org.apache.marmotta.kiwi.test;
-import org.apache.marmotta.commons.vocabulary.XSD;
import org.apache.marmotta.kiwi.caching.CacheManager;
import org.apache.marmotta.kiwi.config.CacheManagerType;
import org.apache.marmotta.kiwi.config.KiWiConfiguration;
@@ -26,12 +25,13 @@ import org.apache.marmotta.kiwi.infinispan.remote.CustomJBossMarshaller;
import org.apache.marmotta.kiwi.test.cluster.BaseClusterTest;
import org.infinispan.client.hotrod.RemoteCache;
import org.infinispan.client.hotrod.RemoteCacheManager;
+import org.infinispan.commons.api.BasicCacheContainer;
+import org.infinispan.commons.equivalence.ByteArrayEquivalence;
import org.infinispan.configuration.cache.CacheMode;
import org.infinispan.configuration.cache.Configuration;
import org.infinispan.configuration.cache.ConfigurationBuilder;
import org.infinispan.configuration.global.GlobalConfiguration;
import org.infinispan.configuration.global.GlobalConfigurationBuilder;
-import org.infinispan.eviction.EvictionStrategy;
import org.infinispan.manager.DefaultCacheManager;
import org.infinispan.manager.EmbeddedCacheManager;
import org.infinispan.server.hotrod.HotRodServer;
@@ -42,8 +42,6 @@ import org.junit.BeforeClass;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.util.concurrent.TimeUnit;
-
/**
* Add file description here!
*
@@ -91,6 +89,8 @@ public class RemoteClusterTest extends BaseClusterTest {
.proxyHost("127.0.0.1")
.proxyPort(port)
.topologyStateTransfer(false)
+ .defaultCacheName(BasicCacheContainer.DEFAULT_CACHE_NAME)
+ .idleTimeout(0)
.workerThreads(2)
.build(true);
@@ -104,13 +104,11 @@ public class RemoteClusterTest extends BaseClusterTest {
Configuration defaultConfiguration = new ConfigurationBuilder()
.clustering()
- .cacheMode(CacheMode.LOCAL)
- .eviction()
- .strategy(EvictionStrategy.LIRS)
- .maxEntries(100000)
- .expiration()
- .lifespan(5, TimeUnit.MINUTES)
- .maxIdle(1, TimeUnit.MINUTES)
+ .cacheMode(CacheMode.LOCAL)
+ .sync()
+ .dataContainer()
+ .keyEquivalence(ByteArrayEquivalence.INSTANCE)
+ .valueEquivalence(ByteArrayEquivalence.INSTANCE)
.build();
EmbeddedCacheManager cacheManager = new DefaultCacheManager(globalConfiguration, defaultConfiguration, true);
@@ -129,7 +127,7 @@ public class RemoteClusterTest extends BaseClusterTest {
cacheManager.getCache(CacheManager.LITERAL_CACHE, true);
cacheManager.getCache(CacheManager.NS_PREFIX_CACHE, true);
cacheManager.getCache(CacheManager.NS_URI_CACHE, true);
- cacheManager.getCache(CacheManager.REGISTRY_CACHE,true);
+ cacheManager.getCache(CacheManager.REGISTRY_CACHE, true);
hotRodServer.start(hotrodConfig, cacheManager);
@@ -148,8 +146,8 @@ public class RemoteClusterTest extends BaseClusterTest {
RemoteCache<String, String> m = remoteCacheManager.getCache();
- m.put(XSD.AnyURI.stringValue(), XSD.AnyURI.stringValue());
- String n = m.get(XSD.AnyURI.stringValue());
+ m.put("xyz", "abc");
+ String n = m.get("xyz");
Assert.assertNotNull(n);