From 86ad8b932cd062b226350c38d1b41ca30e0231d7 Mon Sep 17 00:00:00 2001 From: Nikita Date: Fri, 12 Aug 2016 11:23:00 +0300 Subject: [PATCH] Use codec from config for Executor service --- redisson/src/main/java/org/redisson/Redisson.java | 3 +-- redisson/src/main/java/org/redisson/RedissonClient.java | 3 +-- 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/redisson/src/main/java/org/redisson/Redisson.java b/redisson/src/main/java/org/redisson/Redisson.java index b745ade7e..465229e81 100755 --- a/redisson/src/main/java/org/redisson/Redisson.java +++ b/redisson/src/main/java/org/redisson/Redisson.java @@ -61,7 +61,6 @@ import org.redisson.api.RSortedSet; import org.redisson.api.RTopic; import org.redisson.api.RedissonReactiveClient; import org.redisson.client.codec.Codec; -import org.redisson.codec.SerializationCodec; import org.redisson.command.CommandExecutor; import org.redisson.command.CommandSyncService; import org.redisson.config.Config; @@ -304,7 +303,7 @@ public class Redisson implements RedissonClient { @Override public RExecutorService getExecutorService(String name) { - return new RedissonExecutorService(new SerializationCodec(), commandExecutor, this, name); + return new RedissonExecutorService(connectionManager.getCodec(), commandExecutor, this, name); } @Override diff --git a/redisson/src/main/java/org/redisson/RedissonClient.java b/redisson/src/main/java/org/redisson/RedissonClient.java index 8b5d15311..100840f06 100755 --- a/redisson/src/main/java/org/redisson/RedissonClient.java +++ b/redisson/src/main/java/org/redisson/RedissonClient.java @@ -604,7 +604,6 @@ public interface RedissonClient { /** * Returns ExecutorService by name - * using SerializationCodec codec for task serialization and response/request * * @return */ @@ -612,7 +611,7 @@ public interface RedissonClient { /** * Returns ExecutorService by name - * using provided codec for task serialization and response/request + * using provided codec for task, response and request serialization * * @return */