From 1d337e933633df2e290196cf69b5eabc45a71ace Mon Sep 17 00:00:00 2001 From: xJoeWoo Date: Mon, 20 Apr 2020 22:03:24 +0800 Subject: [PATCH] #2702 Fix RedissonReactiveStringCommands.set using wrong SET RedisCommand Signed-off-by: xJoeWoo --- .../data/connection/RedissonReactiveStringCommands.java | 6 +++--- .../data/connection/RedissonReactiveStringCommands.java | 6 +++--- .../data/connection/RedissonReactiveStringCommands.java | 6 +++--- 3 files changed, 9 insertions(+), 9 deletions(-) diff --git a/redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonReactiveStringCommands.java b/redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonReactiveStringCommands.java index 10aa63bf2..333b2c8aa 100644 --- a/redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonReactiveStringCommands.java +++ b/redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonReactiveStringCommands.java @@ -89,15 +89,15 @@ public class RedissonReactiveStringCommands extends RedissonBaseReactive impleme } } else { if (!command.getOption().isPresent() || command.getOption().get() == SetOption.UPSERT) { - Mono m = write(key, StringCodec.INSTANCE, RedisCommands.SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds()); + Mono m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds()); return m.map(v -> new BooleanResponse<>(command, v)); } if (command.getOption().get() == SetOption.SET_IF_ABSENT) { - Mono m = write(key, StringCodec.INSTANCE, RedisCommands.SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX"); + Mono m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX"); return m.map(v -> new BooleanResponse<>(command, v)); } if (command.getOption().get() == SetOption.SET_IF_PRESENT) { - Mono m = write(key, StringCodec.INSTANCE, RedisCommands.SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX"); + Mono m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX"); return m.map(v -> new BooleanResponse<>(command, v)); } } diff --git a/redisson-spring-data/redisson-spring-data-21/src/main/java/org/redisson/spring/data/connection/RedissonReactiveStringCommands.java b/redisson-spring-data/redisson-spring-data-21/src/main/java/org/redisson/spring/data/connection/RedissonReactiveStringCommands.java index 51a7b6099..a24bd2871 100644 --- a/redisson-spring-data/redisson-spring-data-21/src/main/java/org/redisson/spring/data/connection/RedissonReactiveStringCommands.java +++ b/redisson-spring-data/redisson-spring-data-21/src/main/java/org/redisson/spring/data/connection/RedissonReactiveStringCommands.java @@ -89,15 +89,15 @@ public class RedissonReactiveStringCommands extends RedissonBaseReactive impleme } } else { if (!command.getOption().isPresent() || command.getOption().get() == SetOption.UPSERT) { - Mono m = write(key, StringCodec.INSTANCE, RedisCommands.SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds()); + Mono m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds()); return m.map(v -> new BooleanResponse<>(command, v)); } if (command.getOption().get() == SetOption.SET_IF_ABSENT) { - Mono m = write(key, StringCodec.INSTANCE, RedisCommands.SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX"); + Mono m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX"); return m.map(v -> new BooleanResponse<>(command, v)); } if (command.getOption().get() == SetOption.SET_IF_PRESENT) { - Mono m = write(key, StringCodec.INSTANCE, RedisCommands.SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX"); + Mono m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX"); return m.map(v -> new BooleanResponse<>(command, v)); } } diff --git a/redisson-spring-data/redisson-spring-data-22/src/main/java/org/redisson/spring/data/connection/RedissonReactiveStringCommands.java b/redisson-spring-data/redisson-spring-data-22/src/main/java/org/redisson/spring/data/connection/RedissonReactiveStringCommands.java index 51a7b6099..a24bd2871 100644 --- a/redisson-spring-data/redisson-spring-data-22/src/main/java/org/redisson/spring/data/connection/RedissonReactiveStringCommands.java +++ b/redisson-spring-data/redisson-spring-data-22/src/main/java/org/redisson/spring/data/connection/RedissonReactiveStringCommands.java @@ -89,15 +89,15 @@ public class RedissonReactiveStringCommands extends RedissonBaseReactive impleme } } else { if (!command.getOption().isPresent() || command.getOption().get() == SetOption.UPSERT) { - Mono m = write(key, StringCodec.INSTANCE, RedisCommands.SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds()); + Mono m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds()); return m.map(v -> new BooleanResponse<>(command, v)); } if (command.getOption().get() == SetOption.SET_IF_ABSENT) { - Mono m = write(key, StringCodec.INSTANCE, RedisCommands.SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX"); + Mono m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX"); return m.map(v -> new BooleanResponse<>(command, v)); } if (command.getOption().get() == SetOption.SET_IF_PRESENT) { - Mono m = write(key, StringCodec.INSTANCE, RedisCommands.SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX"); + Mono m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX"); return m.map(v -> new BooleanResponse<>(command, v)); } }