tests fixed

redisson/src/test/java/org/redisson/RedissonBucketTest.java

@@ -21,7 +21,7 @@ public class RedissonBucketTest extends BaseTest {
     public void testSizeInMemory() {
         RBucket<Integer> al = redisson.getBucket("test");
         al.set(1234);
-        assertThat(al.sizeInMemory()).isEqualTo(49);
+        assertThat(al.sizeInMemory()).isEqualTo(55);
     }
     
     @Test

redisson/src/test/java/org/redisson/RedissonFairLockTest.java

@@ -19,6 +19,7 @@ import org.junit.Assert;
 import org.junit.Test;
 import org.redisson.api.RLock;
 import org.redisson.api.RScript;
+import org.redisson.client.codec.LongCodec;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -96,7 +97,7 @@ public class RedissonFairLockTest extends BaseConcurrentTest {
             Assert.fail("Lock should have been unlocked by now");
         }
         //check the timeout scores - they should all be within a reasonable amount of time from now
-        List<Long> queue = redisson.getScript().eval(RScript.Mode.READ_ONLY,
+        List<Long> queue = redisson.getScript(LongCodec.INSTANCE).eval(RScript.Mode.READ_ONLY,
                 "local result = {}; " +
                         "local timeouts = redis.call('zrange', KEYS[1], 0, 99, 'WITHSCORES'); " +
                         "for i=1,#timeouts,2 do " +

redisson/src/test/java/org/redisson/RedissonScriptTest.java

@@ -52,16 +52,16 @@ public class RedissonScriptTest extends BaseTest {
     
     @Test
     public void testEval() {
-        RScript script = redisson.getScript();
-        List<Object> res = script.eval(RScript.Mode.READ_ONLY, "return {1,2,3.3333,'\"foo\"',nil,'bar'}", RScript.ReturnType.MULTI, Collections.emptyList());
-        assertThat(res).containsExactly(1L, 2L, 3L, "foo");
+        RScript script = redisson.getScript(StringCodec.INSTANCE);
+        List<Object> res = script.eval(RScript.Mode.READ_ONLY, "return {'1','2','3.3333','foo',nil,'bar'}", RScript.ReturnType.MULTI, Collections.emptyList());
+        assertThat(res).containsExactly("1", "2", "3.3333", "foo");
     }
 
     @Test
     public void testEvalAsync() {
-        RScript script = redisson.getScript();
-        RFuture<List<Object>> res = script.evalAsync(RScript.Mode.READ_ONLY, "return {1,2,3.3333,'\"foo\"',nil,'bar'}", RScript.ReturnType.MULTI, Collections.emptyList());
-        assertThat(res.awaitUninterruptibly().getNow()).containsExactly(1L, 2L, 3L, "foo");
+        RScript script = redisson.getScript(StringCodec.INSTANCE);
+        RFuture<List<Object>> res = script.evalAsync(RScript.Mode.READ_ONLY, "return {'1','2','3.3333','foo',nil,'bar'}", RScript.ReturnType.MULTI, Collections.emptyList());
+        assertThat(res.awaitUninterruptibly().getNow()).containsExactly("1", "2", "3.3333", "foo");
     }
     
     @Test

redisson/src/test/java/org/redisson/executor/CallableTask.java

 package org.redisson.executor;
 
+import java.io.Serializable;
 import java.util.concurrent.Callable;
 
-public class CallableTask implements Callable<String> {
+public class CallableTask implements Callable<String>, Serializable {
 
     public static final String RESULT = "callable";
     

redisson/src/test/java/org/redisson/executor/DelayedTask.java

 package org.redisson.executor;
 
+import java.io.Serializable;
 import java.util.concurrent.Callable;
 
 import org.redisson.api.RAtomicLong;
 import org.redisson.api.RedissonClient;
 import org.redisson.api.annotation.RInject;
 
-public class DelayedTask implements Callable<Object> {
+public class DelayedTask implements Callable<Object>, Serializable {
 
     @RInject
     private RedissonClient redisson;

redisson/src/test/java/org/redisson/executor/IncrementCallableTask.java

 package org.redisson.executor;
 
+import java.io.Serializable;
 import java.util.concurrent.Callable;
 
 import org.redisson.api.RedissonClient;
 import org.redisson.api.annotation.RInject;
 
-public class IncrementCallableTask implements Callable<String> {
+public class IncrementCallableTask implements Callable<String>, Serializable {
 
     private String counterName;
     

redisson/src/test/java/org/redisson/executor/IncrementRunnableTask.java

 package org.redisson.executor;
 
+import java.io.Serializable;
+
 import org.redisson.api.RedissonClient;
 import org.redisson.api.annotation.RInject;
 
-public class IncrementRunnableTask implements Runnable {
+public class IncrementRunnableTask implements Runnable, Serializable {
 
     private String counterName;
     

redisson/src/test/java/org/redisson/executor/ParameterizedTask.java

 package org.redisson.executor;
 
+import java.io.Serializable;
 import java.util.concurrent.Callable;
 
-public class ParameterizedTask implements Callable<String> {
+public class ParameterizedTask implements Callable<String>, Serializable {
 
     private String param;
     

redisson/src/test/java/org/redisson/executor/RedissonExecutorServiceTest.java

@@ -4,6 +4,7 @@ import static org.assertj.core.api.Assertions.assertThat;
 import static org.awaitility.Awaitility.await;
 
 import java.io.IOException;
+import java.io.Serializable;
 import java.util.Arrays;
 import java.util.Collections;
 import java.util.List;
@@ -515,7 +516,7 @@ public class RedissonExecutorServiceTest extends BaseTest {
         redisson.getExecutorService("test").submit(new TaskCallableClass());
     }
 
-    public static class TaskStaticCallableClass implements Callable<String> {
+    public static class TaskStaticCallableClass implements Callable<String>, Serializable {
 
         @Override
         public String call() throws Exception {
@@ -530,7 +531,7 @@ public class RedissonExecutorServiceTest extends BaseTest {
         assertThat(res).isEqualTo("123");
     }
     
-    public class TaskRunnableClass implements Runnable {
+    public class TaskRunnableClass implements Runnable, Serializable {
 
         @Override
         public void run() {
@@ -543,7 +544,7 @@ public class RedissonExecutorServiceTest extends BaseTest {
         redisson.getExecutorService("test").submit(new TaskRunnableClass());
     }
 
-    public static class TaskStaticRunnableClass implements Runnable {
+    public static class TaskStaticRunnableClass implements Runnable, Serializable {
 
         @Override
         public void run() {

redisson/src/test/java/org/redisson/executor/RunnableRedissonTask.java

 package org.redisson.executor;
 
+import java.io.Serializable;
+
 import org.redisson.api.RedissonClient;
 import org.redisson.api.annotation.RInject;
 
-public class RunnableRedissonTask implements Runnable {
+public class RunnableRedissonTask implements Runnable, Serializable {
 
     @RInject
     private RedissonClient redissonClient;

redisson/src/test/java/org/redisson/executor/RunnableTask.java

 package org.redisson.executor;
 
-public class RunnableTask implements Runnable {
+import java.io.Serializable;
+
+public class RunnableTask implements Runnable, Serializable {
 
     @Override
     public void run() {

redisson/src/test/java/org/redisson/executor/RunnableTask2.java

@@ -2,7 +2,7 @@ package org.redisson.executor;
 
 import java.io.Serializable;
 
-public class RunnableTask2 implements Runnable {
+public class RunnableTask2 implements Runnable, Serializable {
 
     private static final long serialVersionUID = 2105094575950438867L;
     

redisson/src/test/java/org/redisson/executor/ScheduledLongRunnableTask.java

 package org.redisson.executor;
 
+import java.io.Serializable;
+
 import org.redisson.api.RedissonClient;
 import org.redisson.api.annotation.RInject;
 
-public class ScheduledLongRunnableTask implements Runnable {
+public class ScheduledLongRunnableTask implements Runnable, Serializable {
 
     @RInject
     private RedissonClient redisson;