From cd86dfaebb95f0f6d9e73400fba714b2258c5ad2 Mon Sep 17 00:00:00 2001 From: WithLin Date: Sun, 14 Oct 2018 17:27:54 +0800 Subject: [PATCH] Fix CI --- src/CanalSharp.Client/Impl/CanalConnectors.cs | 2 +- src/CanalSharp.Client/Impl/SimpleCanalConnector.cs | 2 -- 2 files changed, 1 insertion(+), 3 deletions(-) diff --git a/src/CanalSharp.Client/Impl/CanalConnectors.cs b/src/CanalSharp.Client/Impl/CanalConnectors.cs index 6ab5c85..f60eb42 100644 --- a/src/CanalSharp.Client/Impl/CanalConnectors.cs +++ b/src/CanalSharp.Client/Impl/CanalConnectors.cs @@ -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; diff --git a/src/CanalSharp.Client/Impl/SimpleCanalConnector.cs b/src/CanalSharp.Client/Impl/SimpleCanalConnector.cs index 31e1017..2fe2cce 100644 --- a/src/CanalSharp.Client/Impl/SimpleCanalConnector.cs +++ b/src/CanalSharp.Client/Impl/SimpleCanalConnector.cs @@ -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;