From 3c70fb66133eab93bee45a76e1bf258a8aec6ee9 Mon Sep 17 00:00:00 2001 From: dengliming Date: Sat, 27 Feb 2021 19:16:02 +0800 Subject: [PATCH] Optimize Jedis KEEPTTL command parameter convert --- .../connection/jedis/JedisConverters.java | 19 +++---------------- 1 file changed, 3 insertions(+), 16 deletions(-) diff --git a/src/main/java/org/springframework/data/redis/connection/jedis/JedisConverters.java b/src/main/java/org/springframework/data/redis/connection/jedis/JedisConverters.java index 5e34e143e5..8cb435bc8c 100644 --- a/src/main/java/org/springframework/data/redis/connection/jedis/JedisConverters.java +++ b/src/main/java/org/springframework/data/redis/connection/jedis/JedisConverters.java @@ -88,6 +88,7 @@ * @author Mark Paluch * @author Ninad Divadkar * @author Guy Korland + * @author dengliming */ public abstract class JedisConverters extends Converters { @@ -424,21 +425,7 @@ public static SetParams toSetCommandExPxArgument(Expiration expiration, SetParam SetParams paramsToUse = params == null ? SetParams.setParams() : params; if (expiration.isKeepTtl()) { - - // TODO: remove once jedis supports KEEPTTL (https://github.com/xetorthio/jedis/issues/2248) - return new SetParams() { - - @Override - public byte[][] getByteParams(byte[]... args) { - - ArrayList byteParams = new ArrayList<>(); - for (byte[] arg : paramsToUse.getByteParams(args)) { - byteParams.add(arg); - } - byteParams.add(SafeEncoder.encode("keepttl")); - return byteParams.toArray(new byte[byteParams.size()][]); - } - }; + return paramsToUse.keepttl(); } if (!expiration.isPersistent()) { @@ -700,7 +687,7 @@ public static GeoRadiusParam toGeoRadiusParam(GeoRadiusCommandArgs source) { /** * Convert given {@link BitFieldSubCommands} into argument array. * - * @param bitfieldOperation + * @param source * @return never {@literal null}. * @since 1.8 */