refactor the code

Author: withlin

sample/CanalSharp.SimpleClient/Program.cs

@@ -15,30 +15,17 @@ static void Main(string[] args)
             var connector = CanalConnectors.NewSingleConnector("127.0.0.1", 11111, destination, "", "");
             connector.Connect();
             connector.Subscribe();
-            try
+            while (true)
             {
-                while (true)
+                var message = connector.Get(5000);
+                var batchId = message.Id;
+                if (batchId == -1 || message.Entries.Count <= 0)
                 {
-                    var message = connector.GetWithoutAck(5000);
-                    var batchId = message.Id;
-                    if (batchId == -1 || message.Entries.Count <= 0)
-                    {
-                        Console.WriteLine("=======没有数据了=======");
-                        Thread.Sleep(300);
-                        continue;
-                    }
-                    PrintEntry(message.Entries);
-
-                    connector.Ack(batchId);
+                    Console.WriteLine("没有数据了.............");
+                    Thread.Sleep(300);
                 }
+                PrintEntry(message.Entries);
             }
-            catch (Exception e)
-            {
-                Console.WriteLine(e);
-                connector.Rollback();
-                throw;
-            }
-            
         }
 
         private static void PrintEntry(List<Entry> entrys)

src/CanalSharp.Common/AbstractCanalLifeCycle.cs

@@ -1,8 +1,4 @@
-// #region File Annotation
-// 
-
-
-using CanalSharp.Common.Exception;
+using CanalSharp.Common.Exception;
 
 namespace CanalSharp.Common
 {
@@ -19,7 +15,7 @@ public virtual void Start()
         {
             if (Running)
             {
-                throw new CanalException(this.GetType().Name + " has startup , don't repeat start");
+                throw new CanalException($" {nameof(AbstractCanalLifeCycle)} has startup , don't repeat start");
             }
 
             Running = true;
@@ -29,7 +25,7 @@ public virtual void Stop()
         {
             if (!Running)
             {
-                throw new CanalException(this.GetType().Name + " isn't start , please check");
+                throw new CanalException($"{nameof(AbstractCanalLifeCycle)} isn't start , please check");
             }
 
             Running = false;

test/CanalSharp.UnitTests/UnitTest1.cs

@@ -17,6 +17,8 @@ public void Test1()
             ICanalConnector connector = CanalConnectors.NewSingleConnector("127.0.0.1", 11111, destination, "", "");
             connector.Connect();
             Console.Read();
+
+            Mutex a=new Mutex(false);
             //lock (_lock)
             //{
             //    new Thread(Test).Start();