#358 fix Letuci integration

bucket4j · May 2, 2023 · a353e75 · a353e75
1 parent e32aa40
commit a353e75
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/...4j-redis/src/main/java/io/github/bucket4j/redis/lettuce/cas/LettuceBasedProxyManager.java b/...4j-redis/src/main/java/io/github/bucket4j/redis/lettuce/cas/LettuceBasedProxyManager.java
@@ -68,7 +68,7 @@ public RedisFuture<Void> delete(byte[] key) {
                 return (RedisFuture) redisAsyncCommands.del(key);
             }
         };
-        return new LettuceBasedProxyManagerBuilder(redisApi);
+        return new LettuceBasedProxyManagerBuilder(Mapper.BYTES, redisApi);
     }
 
     public static LettuceBasedProxyManagerBuilder<byte[]> builderFor(StatefulRedisConnection<byte[], byte[]> statefulRedisConnection) {
@@ -103,16 +103,17 @@ public RedisFuture<Void> delete(byte[] key) {
                 return (RedisFuture) redisAsyncCommands.del(key);
             }
         };
-        return new LettuceBasedProxyManagerBuilder<>(redisApi);
+        return new LettuceBasedProxyManagerBuilder<>(Mapper.BYTES, redisApi);
     }
 
     public static class LettuceBasedProxyManagerBuilder<K> extends AbstractRedisProxyManagerBuilder<LettuceBasedProxyManagerBuilder<K>> {
 
         private final RedisApi redisApi;
         private Mapper<K> keyMapper;
 
-        private LettuceBasedProxyManagerBuilder(RedisApi redisApi) {
+        private LettuceBasedProxyManagerBuilder(Mapper<K> keyMapper, RedisApi redisApi) {
             this.redisApi = Objects.requireNonNull(redisApi);
+            this.keyMapper = keyMapper;
         }
 
         public <Key> LettuceBasedProxyManagerBuilder<Key> withKeyMapper(Mapper<Key> keyMapper) {