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

Merge pull request #2709 from xJoeWoo/fix-wrong-set-command

Browse Source 
#2702 Fix RedissonReactiveStringCommands.set using wrong SET RedisCommand
pull/2776/head
Nikita Koksharov 5 years ago committed by GitHub
parent c2fde5b0fa 1d337e9336
commit 9f04fd1617
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
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 {
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));
}
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));
}
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));
}
}

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 {
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));
}
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));
}
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));
}
}

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 {
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));
}
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));
}
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));
}
}

Write Preview
Loading…
Cancel
Save