Update ClusterCanalConnector.java

This commit is contained in:
lulu2panpan
2016-04-29 09:28:12 +08:00
parent 44f2b74862
commit 8ded94a09e

View File

@@ -45,7 +45,7 @@ public class ClusterCanalConnector implements CanalConnector {
int times = 0; int times = 0;
while (true) { while (true) {
try { try {
currentConnector = new SimpleCanalConnector(nextAddress, username, password, destination); currentConnector = new SimpleCanalConnector(nextAddress, username, password, destination, ,accessStrategy);
currentConnector.setSoTimeout(soTimeout); currentConnector.setSoTimeout(soTimeout);
if (filter != null) { if (filter != null) {
currentConnector.setFilter(filter); currentConnector.setFilter(filter);
@@ -57,7 +57,7 @@ public class ClusterCanalConnector implements CanalConnector {
currentConnector.connect(); currentConnector.connect();
break; break;
} catch (Exception e) { } catch (Exception e) {
logger.warn("failed to connect to:{} after retry {} times", nextAddress, times); logger.warn("failed to connect to:{} after retry {} times", currentConnector.getAddress(), times);
currentConnector.disconnect(); currentConnector.disconnect();
currentConnector = null; currentConnector = null;
// retry for #retryTimes for each node when trying to // retry for #retryTimes for each node when trying to