refactor.

samples/Sample.Kafka/Controllers/ValuesController.cs

@@ -29,9 +29,7 @@ namespace Sample.Kafka.Controllers
         [CapSubscribe("zzwl.topic.finace.callBack", Group = "test")]
         public void KafkaTest(Person person)
         {
-            Console.WriteLine(person.Name);
-            Console.WriteLine(person.Age);
-
+            Console.WriteLine(DateTime.Now);
         }
 
         [Route("~/send")]

src/DotNetCore.CAP/Infrastructure/Helper.cs

@@ -6,7 +6,7 @@ namespace DotNetCore.CAP.Infrastructure
 {
     public static class Helper
     {
-        private static readonly DateTime Epoch = new DateTime(1970, 1, 1, 0, 0, 0, DateTimeKind.Utc);
+        private static readonly DateTime Epoch = new DateTime(1970, 1, 1, 0, 0, 0, DateTimeKind.Local);
         private static JsonSerializerSettings _serializerSettings;
 
         public static void SetSerializerSettings(JsonSerializerSettings setting)

src/DotNetCore.CAP/Infrastructure/WebHookProvider.cs

@@ -4,7 +4,11 @@ using System.Text;
 
 namespace DotNetCore.CAP.Infrastructure
 {
-    class WebHookProvider
+    public class WebHookProvider
     {
+        public WebHookProvider()
+        {
+            throw new NotImplementedException();
+        }
     }
 }

src/DotNetCore.CAP/Processor/IProcessingServer.Cap.cs

@@ -59,10 +59,9 @@ namespace DotNetCore.CAP.Processor
                 return;
             }
 
-            _logger.LogTrace("Pulsing the JobQueuer.");
+            _logger.LogTrace("Pulsing the Queuer.");
 
-            PublishQueuer.PulseEvent.Set();
-            SubscribeQueuer.PulseEvent.Set();
+            PublishQueuer.PulseEvent.Set();          
         }
 
         public void Dispose()