|
@@ -52,18 +52,17 @@ public class RedissonConfig {
|
|
|
if(qserver) {
|
|
if(qserver) {
|
|
|
sentinelServersConfig.setSubscriptionConnectionMinimumIdleSize(QueueServer.getSubscriptionCount());
|
|
sentinelServersConfig.setSubscriptionConnectionMinimumIdleSize(QueueServer.getSubscriptionCount());
|
|
|
}
|
|
}
|
|
|
- sentinelServersConfig.setPingConnectionInterval(1000);
|
|
|
|
|
|
|
+ sentinelServersConfig.setPingConnectionInterval(90*1000);
|
|
|
sentinelServersConfig.setDatabase(database);
|
|
sentinelServersConfig.setDatabase(database);
|
|
|
}else {
|
|
}else {
|
|
|
SingleServerConfig singleServerConfig = config.useSingleServer()
|
|
SingleServerConfig singleServerConfig = config.useSingleServer()
|
|
|
.setConnectionMinimumIdleSize(minimumIdleSize)
|
|
.setConnectionMinimumIdleSize(minimumIdleSize)
|
|
|
.setConnectionPoolSize(connectionPoolSize)
|
|
.setConnectionPoolSize(connectionPoolSize)
|
|
|
- .setAddress("redis://" + redisHosts[0])
|
|
|
|
|
- .setPingConnectionInterval(1000);
|
|
|
|
|
|
|
+ .setAddress("redis://" + redisHosts[0]);
|
|
|
if(qserver) {
|
|
if(qserver) {
|
|
|
singleServerConfig.setSubscriptionConnectionMinimumIdleSize(QueueServer.getSubscriptionCount());
|
|
singleServerConfig.setSubscriptionConnectionMinimumIdleSize(QueueServer.getSubscriptionCount());
|
|
|
}
|
|
}
|
|
|
- singleServerConfig.setPingConnectionInterval(1000);
|
|
|
|
|
|
|
+ singleServerConfig.setPingConnectionInterval(90*1000);
|
|
|
singleServerConfig.setDatabase(database);
|
|
singleServerConfig.setDatabase(database);
|
|
|
}
|
|
}
|
|
|
RedissonClient redisson = Redisson.create(config);
|
|
RedissonClient redisson = Redisson.create(config);
|