|
|
|
@ -22,6 +22,7 @@ import org.springframework.context.annotation.Configuration; |
|
|
|
import org.springframework.data.redis.connection.RedisSentinelConfiguration; |
|
|
|
import org.springframework.data.redis.connection.jedis.JedisClientConfiguration; |
|
|
|
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory; |
|
|
|
import org.thingsboard.server.common.data.StringUtils; |
|
|
|
|
|
|
|
@Configuration |
|
|
|
@ConditionalOnMissingBean(TbCaffeineCacheConfiguration.class) |
|
|
|
@ -46,6 +47,9 @@ public class TBRedisSentinelConfiguration extends TBRedisCacheConfiguration { |
|
|
|
@Value("${redis.ssl.enabled:false}") |
|
|
|
private boolean useSsl; |
|
|
|
|
|
|
|
@Value("${redis.username:}") |
|
|
|
private String username; |
|
|
|
|
|
|
|
@Value("${redis.password:}") |
|
|
|
private String password; |
|
|
|
|
|
|
|
@ -54,9 +58,10 @@ public class TBRedisSentinelConfiguration extends TBRedisCacheConfiguration { |
|
|
|
redisSentinelConfiguration.setMaster(master); |
|
|
|
redisSentinelConfiguration.setSentinels(getNodes(sentinels)); |
|
|
|
redisSentinelConfiguration.setSentinelPassword(sentinelPassword); |
|
|
|
redisSentinelConfiguration.setUsername(username); |
|
|
|
redisSentinelConfiguration.setPassword(password); |
|
|
|
redisSentinelConfiguration.setDatabase(database); |
|
|
|
return new JedisConnectionFactory(redisSentinelConfiguration, buildClientConfig()); |
|
|
|
return new JedisConnectionFactory(redisSentinelConfiguration, buildClientConfig()); |
|
|
|
} |
|
|
|
|
|
|
|
private JedisClientConfiguration buildClientConfig() { |
|
|
|
@ -73,4 +78,5 @@ public class TBRedisSentinelConfiguration extends TBRedisCacheConfiguration { |
|
|
|
} |
|
|
|
return jedisClientConfigurationBuilder.build(); |
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|