Fixed a poorly-mirrored write operation to the new cluster.
This commit is contained in:
parent
a0bebca1e6
commit
17cfd4924c
|
@ -181,18 +181,16 @@ public class UsernamesManager {
|
||||||
final String uuidMapKey = getUuidMapKey(uuid);
|
final String uuidMapKey = getUuidMapKey(uuid);
|
||||||
|
|
||||||
redisGet(uuid).ifPresent(username -> {
|
redisGet(uuid).ifPresent(username -> {
|
||||||
jedis.del(getUsernameMapKey(username));
|
final String usernameMapKey = getUsernameMapKey(username);
|
||||||
|
|
||||||
|
jedis.del(usernameMapKey);
|
||||||
jedis.del(uuidMapKey);
|
jedis.del(uuidMapKey);
|
||||||
});
|
|
||||||
|
|
||||||
cacheCluster.useWriteCluster(connection -> {
|
cacheCluster.useWriteCluster(connection -> {
|
||||||
final RedisAdvancedClusterAsyncCommands<String, String> asyncCommands = connection.async();
|
final RedisAdvancedClusterAsyncCommands<String, String> asyncCommands = connection.async();
|
||||||
|
|
||||||
asyncCommands.get(uuidMapKey).thenAccept(username -> {
|
asyncCommands.del(usernameMapKey);
|
||||||
if (username != null) {
|
asyncCommands.del(uuidMapKey);
|
||||||
asyncCommands.del(getUsernameMapKey(username));
|
|
||||||
asyncCommands.del(uuidMapKey);
|
|
||||||
}
|
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue