diff --git a/redisson-spring-data/redisson-spring-data-16/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java b/redisson-spring-data/redisson-spring-data-16/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java index e29dd63a5..39e0481b5 100644 --- a/redisson-spring-data/redisson-spring-data-16/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java +++ b/redisson-spring-data/redisson-spring-data-16/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java @@ -324,7 +324,7 @@ public class RedissonConnection extends AbstractRedisConnection { } Set results = new HashSet(); - RFuture> f = (RFuture>)(Object)(executorService.readAllAsync(results, StringCodec.INSTANCE, KEYS, pattern)); + RFuture> f = (RFuture>)(Object)(executorService.readAllAsync(results, ByteArrayCodec.INSTANCE, KEYS, pattern)); return sync(f); } diff --git a/redisson-spring-data/redisson-spring-data-17/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java b/redisson-spring-data/redisson-spring-data-17/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java index 605cde25e..19c0423da 100644 --- a/redisson-spring-data/redisson-spring-data-17/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java +++ b/redisson-spring-data/redisson-spring-data-17/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java @@ -326,7 +326,7 @@ public class RedissonConnection extends AbstractRedisConnection { } Set results = new HashSet(); - RFuture> f = (RFuture>)(Object)(executorService.readAllAsync(results, StringCodec.INSTANCE, KEYS, pattern)); + RFuture> f = (RFuture>)(Object)(executorService.readAllAsync(results, ByteArrayCodec.INSTANCE, KEYS, pattern)); return sync(f); } diff --git a/redisson-spring-data/redisson-spring-data-18/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java b/redisson-spring-data/redisson-spring-data-18/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java index 2426691ea..786b5cb7b 100644 --- a/redisson-spring-data/redisson-spring-data-18/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java +++ b/redisson-spring-data/redisson-spring-data-18/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java @@ -335,7 +335,7 @@ public class RedissonConnection extends AbstractRedisConnection { } Set results = new HashSet(); - RFuture> f = (RFuture>)(Object)(executorService.readAllAsync(results, StringCodec.INSTANCE, KEYS, pattern)); + RFuture> f = (RFuture>)(Object)(executorService.readAllAsync(results, ByteArrayCodec.INSTANCE, KEYS, pattern)); return sync(f); } diff --git a/redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java b/redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java index 56830866b..ab7fb7f95 100644 --- a/redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java +++ b/redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java @@ -336,7 +336,7 @@ public class RedissonConnection extends AbstractRedisConnection { } Set results = new HashSet(); - RFuture> f = (RFuture>)(Object)(executorService.readAllAsync(results, StringCodec.INSTANCE, KEYS, pattern)); + RFuture> f = (RFuture>)(Object)(executorService.readAllAsync(results, ByteArrayCodec.INSTANCE, KEYS, pattern)); return sync(f); }