Skip to content

Commit

Permalink
fix bug
Browse files Browse the repository at this point in the history
  • Loading branch information
ldang264 committed Aug 26, 2021
1 parent 872836b commit 6c0e22a
Showing 1 changed file with 4 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -469,8 +469,7 @@ public void initialize(ClassLoadHelper loadHelper, SchedulerSignaler signaler) {
.setRedisScriptingCommands(sync)
.setRedisHashCommands(sync)
.setRedisSetCommands(sync)
.setRedisSortedSetCommands(sync)
.setRedisServerCommands(sync);
.setRedisSortedSetCommands(sync);
} else if (sentinelNodes != null && sentinelNodes.trim().length() > 0) {
String[] uris = sentinelNodes.split(",");
RedisURI.Builder builder = RedisURI.builder()
Expand Down Expand Up @@ -506,8 +505,7 @@ public void initialize(ClassLoadHelper loadHelper, SchedulerSignaler signaler) {
.setRedisScriptingCommands(sync)
.setRedisHashCommands(sync)
.setRedisSetCommands(sync)
.setRedisSortedSetCommands(sync)
.setRedisServerCommands(sync);
.setRedisSortedSetCommands(sync);
} else if (uri != null && uri.trim().length() > 0) {
RedisClient redisClient = RedisClient.create(uri);
StatefulRedisConnection<String, String> connection = redisClient.connect();
Expand All @@ -519,8 +517,7 @@ public void initialize(ClassLoadHelper loadHelper, SchedulerSignaler signaler) {
.setRedisScriptingCommands(sync)
.setRedisHashCommands(sync)
.setRedisSetCommands(sync)
.setRedisSortedSetCommands(sync)
.setRedisServerCommands(sync);
.setRedisSortedSetCommands(sync);
} else {
RedisURI redisURI = RedisURI.Builder.redis(host, port).withSsl(ssl).withDatabase(database).build();
if (password != null && !"".equals(password.trim())) {
Expand All @@ -536,8 +533,7 @@ public void initialize(ClassLoadHelper loadHelper, SchedulerSignaler signaler) {
.setRedisScriptingCommands(sync)
.setRedisHashCommands(sync)
.setRedisSetCommands(sync)
.setRedisSortedSetCommands(sync)
.setRedisServerCommands(sync);
.setRedisSortedSetCommands(sync);
}

}
Expand Down

0 comments on commit 6c0e22a

Please sign in to comment.