github-forks
/
redisson
mirror of https://github.com/redisson/redisson.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

#2702 Fix RedissonReactiveStringCommands.set using wrong SET RedisCommand

Browse Source 
Signed-off-by: xJoeWoo <xjoewoo@gmail.com>
pull/2709/head
xJoeWoo 5 years ago
parent bf8e9d358e
commit 1d337e9336
3 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File

6
redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonReactiveStringCommands.java
Unescape Escape View File

@ -89,15 +89,15 @@ public class RedissonReactiveStringCommands extends RedissonBaseReactive impleme
} }
} else { } else {
if (!command.getOption().isPresent() || command.getOption().get() == SetOption.UPSERT) { if (!command.getOption().isPresent() || command.getOption().get() == SetOption.UPSERT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, RedisCommands.SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds()); Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds());
return m.map(v -> new BooleanResponse<>(command, v)); return m.map(v -> new BooleanResponse<>(command, v));
} }
if (command.getOption().get() == SetOption.SET_IF_ABSENT) { if (command.getOption().get() == SetOption.SET_IF_ABSENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, RedisCommands.SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX"); Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX");
return m.map(v -> new BooleanResponse<>(command, v)); return m.map(v -> new BooleanResponse<>(command, v));
} }
if (command.getOption().get() == SetOption.SET_IF_PRESENT) { if (command.getOption().get() == SetOption.SET_IF_PRESENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, RedisCommands.SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX"); Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX");
return m.map(v -> new BooleanResponse<>(command, v)); return m.map(v -> new BooleanResponse<>(command, v));
} }
} }

6
redisson-spring-data/redisson-spring-data-21/src/main/java/org/redisson/spring/data/connection/RedissonReactiveStringCommands.java
Unescape Escape View File

@ -89,15 +89,15 @@ public class RedissonReactiveStringCommands extends RedissonBaseReactive impleme
} }
} else { } else {
if (!command.getOption().isPresent() || command.getOption().get() == SetOption.UPSERT) { if (!command.getOption().isPresent() || command.getOption().get() == SetOption.UPSERT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, RedisCommands.SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds()); Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds());
return m.map(v -> new BooleanResponse<>(command, v)); return m.map(v -> new BooleanResponse<>(command, v));
} }
if (command.getOption().get() == SetOption.SET_IF_ABSENT) { if (command.getOption().get() == SetOption.SET_IF_ABSENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, RedisCommands.SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX"); Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX");
return m.map(v -> new BooleanResponse<>(command, v)); return m.map(v -> new BooleanResponse<>(command, v));
} }
if (command.getOption().get() == SetOption.SET_IF_PRESENT) { if (command.getOption().get() == SetOption.SET_IF_PRESENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, RedisCommands.SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX"); Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX");
return m.map(v -> new BooleanResponse<>(command, v)); return m.map(v -> new BooleanResponse<>(command, v));
} }
} }

6
redisson-spring-data/redisson-spring-data-22/src/main/java/org/redisson/spring/data/connection/RedissonReactiveStringCommands.java
Unescape Escape View File

@ -89,15 +89,15 @@ public class RedissonReactiveStringCommands extends RedissonBaseReactive impleme
} }
} else { } else {
if (!command.getOption().isPresent() || command.getOption().get() == SetOption.UPSERT) { if (!command.getOption().isPresent() || command.getOption().get() == SetOption.UPSERT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, RedisCommands.SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds()); Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds());
return m.map(v -> new BooleanResponse<>(command, v)); return m.map(v -> new BooleanResponse<>(command, v));
} }
if (command.getOption().get() == SetOption.SET_IF_ABSENT) { if (command.getOption().get() == SetOption.SET_IF_ABSENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, RedisCommands.SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX"); Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX");
return m.map(v -> new BooleanResponse<>(command, v)); return m.map(v -> new BooleanResponse<>(command, v));
} }
if (command.getOption().get() == SetOption.SET_IF_PRESENT) { if (command.getOption().get() == SetOption.SET_IF_PRESENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, RedisCommands.SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX"); Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX");
return m.map(v -> new BooleanResponse<>(command, v)); return m.map(v -> new BooleanResponse<>(command, v));
} }
} }

Write Preview
Loading…
Cancel
Save