diff --git a/src/main/java/com/alibaba/druid/pool/ha/MultiDataSource.java b/src/main/java/com/alibaba/druid/pool/ha/MultiDataSource.java index 78ff08932d..c7b4a2c72f 100644 --- a/src/main/java/com/alibaba/druid/pool/ha/MultiDataSource.java +++ b/src/main/java/com/alibaba/druid/pool/ha/MultiDataSource.java @@ -47,7 +47,7 @@ public abstract class MultiDataSource extends DataSourceAdapter implements Multi private final AtomicLong busySkipCount = new AtomicLong(); private final AtomicLong retryGetConnectionCount = new AtomicLong(); - protected DataSourceFailureDetecter failureDetector = new DefaultDataSourceFailureDetecter(); + protected DataSourceFailureDetecter failureDetector = new DefaultDataSourceFailureDetecter(); private long failureDetectPeriodMillis = 3000; private long configLoadPeriodMillis = 1000 * 60; @@ -240,12 +240,12 @@ public abstract class MultiDataSource extends DataSourceAdapter implements Multi this.failureDetectPeriodMillis = validDataSourceCheckPeriodMillis; } - public DataSourceFailureDetecter getValidDataSourceChecker() { + public DataSourceFailureDetecter getFailureDetector() { return failureDetector; } - public void setValidDataSourceChecker(DataSourceFailureDetecter validDataSourceChecker) { - this.failureDetector = validDataSourceChecker; + public void setFailureDetector(DataSourceFailureDetecter failureDetector) { + this.failureDetector = failureDetector; } public long createConnectionId() { diff --git a/src/main/java/com/alibaba/druid/pool/ha/cobar/CobarDataSource.java b/src/main/java/com/alibaba/druid/pool/ha/cobar/CobarDataSource.java index b70f81fe32..b13dfae2d5 100644 --- a/src/main/java/com/alibaba/druid/pool/ha/cobar/CobarDataSource.java +++ b/src/main/java/com/alibaba/druid/pool/ha/cobar/CobarDataSource.java @@ -26,7 +26,7 @@ public class CobarDataSource extends MultiDataSource { private String filters; public CobarDataSource(){ - + this.setFailureDetector(new CobarFailureDetecter()); } public String getUrl() {