chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

Update CanalConnectors.java

Browse Source
This commit is contained in:
lulu2panpan
2016-04-29 09:31:40 +08:00
parent e614c6141d
commit 11e1d1d600
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
client/src/main/java/com/alibaba/otter/canal/client/CanalConnectors.java
View File

@@ -28,7 +28,7 @@ public class CanalConnectors {
*/ */
public static CanalConnector newSingleConnector(SocketAddress address, String destination, String username, public static CanalConnector newSingleConnector(SocketAddress address, String destination, String username,
String password) { String password) {
SimpleCanalConnector canalConnector = new SimpleCanalConnector(address, username, password, destination); SimpleCanalConnector canalConnector = new SimpleCanalConnector(address, username, password, destination, null);
canalConnector.setSoTimeout(30 * 1000); canalConnector.setSoTimeout(30 * 1000);
return canalConnector; return canalConnector;
} }