This commit is contained in:
WithLin
2018-10-14 17:27:54 +08:00
parent b0a8079f6a
commit cd86dfaebb
2 changed files with 1 additions and 3 deletions
@@ -31,7 +31,7 @@ namespace CanalSharp.Client.Impl
{
var canalConnector = new SimpleCanalConnector(address, port, username, password, destination)
{
SoTimeout = 60 * 1000,
SoTimeOut = 60 * 1000,
IdleTimeOut = 60 * 60 * 1000
};
return canalConnector;
@@ -19,13 +19,11 @@ using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net.Sockets;
using System.Threading.Tasks;
using CanalSharp.Common.Logging;
using CanalSharp.Protocol;
using CanalSharp.Protocol.Exception;
using Com.Alibaba.Otter.Canal.Protocol;
using DotNetty.Transport.Channels;
using DotNetty.Transport.Channels.Sockets;
using Google.Protobuf;
using Microsoft.Extensions.Logging;