Add a version of RedissonLocalCachedMapTest that uses the SerializationCodec.

Fix most of the tests by making classes implement Serializable.
The testAddAndGet test is still failing and after an hour of looking through it, I still can't figure why.
pull/748/head
Jarrod Ribble 8 years ago
parent 4a8259cb05
commit 2cb015842d

@ -15,6 +15,7 @@
*/
package org.redisson;
import java.io.Serializable;
import java.math.BigDecimal;
import java.util.AbstractCollection;
import java.util.AbstractMap;
@ -65,11 +66,11 @@ import io.netty.util.internal.ThreadLocalRandom;
*/
public class RedissonLocalCachedMap<K, V> extends RedissonMap<K, V> implements RLocalCachedMap<K, V> {
public static class LocalCachedMapClear {
public static class LocalCachedMapClear implements Serializable {
}
public static class LocalCachedMapInvalidate {
public static class LocalCachedMapInvalidate implements Serializable {
private byte[] excludedId;
private byte[] keyHash;
@ -93,7 +94,7 @@ public class RedissonLocalCachedMap<K, V> extends RedissonMap<K, V> implements R
}
public static class CacheKey {
public static class CacheKey implements Serializable {
private final byte[] keyHash;
@ -135,7 +136,7 @@ public class RedissonLocalCachedMap<K, V> extends RedissonMap<K, V> implements R
}
public static class CacheValue {
public static class CacheValue implements Serializable {
private final Object key;
private final Object value;

@ -0,0 +1,46 @@
package org.redisson;
import org.junit.Before;
import org.junit.BeforeClass;
import org.redisson.api.RedissonClient;
import org.redisson.codec.SerializationCodec;
import org.redisson.config.Config;
import java.io.IOException;
/**
* Created by jribble on 1/12/17.
*/
public class RedissonLocalCachedMapSerializationCodecTest extends RedissonLocalCachedMapTest {
public static Config createConfig() {
Config config = RedissonLocalCachedMapTest.createConfig();
config.setCodec(new SerializationCodec());
return config;
}
public static RedissonClient createInstance() {
Config config = createConfig();
return Redisson.create(config);
}
@BeforeClass
public static void beforeClass() throws IOException, InterruptedException {
if (!RedissonRuntimeEnvironment.isTravis) {
RedisRunner.startDefaultRedisServerInstance();
defaultRedisson = createInstance();
}
}
@Before
public void before() throws IOException, InterruptedException {
if (RedissonRuntimeEnvironment.isTravis) {
RedisRunner.startDefaultRedisServerInstance();
redisson = createInstance();
} else {
if (redisson == null) {
redisson = defaultRedisson;
}
redisson.getKeys().flushall();
}
}
}

@ -27,7 +27,7 @@ import mockit.Deencapsulation;
public class RedissonLocalCachedMapTest extends BaseTest {
// @Test
// @Test
public void testPerf() {
LocalCachedMapOptions options = LocalCachedMapOptions.defaults().evictionPolicy(EvictionPolicy.LFU).cacheSize(100000).invalidateEntryOnChange(true);
Map<String, Integer> map = redisson.getLocalCachedMap("test", options);

Loading…
Cancel
Save