refactoring

pull/1423/head
Nikita 7 years ago
parent d4c35a34f1
commit 5c68c38c6d

@ -57,15 +57,6 @@ public class SingleServerConfig extends BaseConfig<SingleServerConfig> {
*/
private int database = 0;
/**
* Should the server address be monitored for changes in DNS? Useful for
* AWS ElastiCache where the client is pointed at the endpoint for a replication group
* which is a DNS alias to the current master node.<br>
* <em>NB: applications must ensure the JVM DNS cache TTL is low enough to support this.</em>
* e.g., http://docs.aws.amazon.com/AWSSdkDocsJava/latest/DeveloperGuide/java-dg-jvm-ttl.html
*/
private boolean dnsMonitoring = true;
/**
* Interval in milliseconds to check DNS
*/
@ -79,7 +70,6 @@ public class SingleServerConfig extends BaseConfig<SingleServerConfig> {
setAddress(config.getAddress());
setConnectionPoolSize(config.getConnectionPoolSize());
setSubscriptionConnectionPoolSize(config.getSubscriptionConnectionPoolSize());
setDnsMonitoring(config.isDnsMonitoring());
setDnsMonitoringInterval(config.getDnsMonitoringInterval());
setSubscriptionConnectionMinimumIdleSize(config.getSubscriptionConnectionMinimumIdleSize());
setConnectionMinimumIdleSize(config.getConnectionMinimumIdleSize());
@ -143,27 +133,11 @@ public class SingleServerConfig extends BaseConfig<SingleServerConfig> {
}
/**
* Monitoring of the endpoint address for DNS changes.
* <p>
* Applications must ensure the JVM DNS cache TTL is low enough to support this
* Interval in milliseconds to check the endpoint's DNS<p>
* Applications must ensure the JVM DNS cache TTL is low enough to support this.<p>
* Set <code>-1</code> to disable.
* <p>
* Default is <code>true</code>
*
* @param dnsMonitoring flag
* @return config
*/
public SingleServerConfig setDnsMonitoring(boolean dnsMonitoring) {
this.dnsMonitoring = dnsMonitoring;
return this;
}
public boolean isDnsMonitoring() {
return dnsMonitoring;
}
/**
* Interval in milliseconds to check the endpoint DNS if {@link #isDnsMonitoring()} is true.
*
* Default is <code>5000</code>
* Default is <code>5000</code>.
*
* @param dnsMonitoringInterval time
* @return config

@ -57,11 +57,7 @@ public class SingleConnectionManager extends MasterSlaveConnectionManager {
newconfig.setSubscriptionConnectionPoolSize(cfg.getSubscriptionConnectionPoolSize());
newconfig.setConnectTimeout(cfg.getConnectTimeout());
newconfig.setIdleConnectionTimeout(cfg.getIdleConnectionTimeout());
if (cfg.isDnsMonitoring()) {
newconfig.setDnsMonitoringInterval(cfg.getDnsMonitoringInterval());
} else {
newconfig.setDnsMonitoringInterval(-1);
}
newconfig.setDnsMonitoringInterval(cfg.getDnsMonitoringInterval());
newconfig.setMasterConnectionMinimumIdleSize(cfg.getConnectionMinimumIdleSize());
newconfig.setSubscriptionConnectionMinimumIdleSize(cfg.getSubscriptionConnectionMinimumIdleSize());

Loading…
Cancel
Save