refactor Diagnostics module.

src/DotNetCore.CAP/Diagnostics/EventData.Broker.Consume.cs

+using System;
+
+namespace DotNetCore.CAP.Diagnostics
+{
+    public class BrokerConsumeEventData : BrokerEventData
+    {
+        public DateTimeOffset StartTime { get; }
+
+        public BrokerConsumeEventData(Guid operationId, string operation, string groupName,
+            string brokerTopicName, string brokerTopicBody, DateTimeOffset startTime)
+            : base(operationId, operation, groupName, brokerTopicName, brokerTopicBody)
+        {
+            StartTime = startTime;
+        }
+    }
+}

src/DotNetCore.CAP/Diagnostics/EventData.Broker.ConsumeEnd.cs

+using System;
+
+namespace DotNetCore.CAP.Diagnostics
+{
+    public class BrokerConsumeEndEventData : BrokerConsumeEventData
+    {
+        public TimeSpan Duration { get; }
+
+        public BrokerConsumeEndEventData(Guid operationId, string operation, string groupName, string brokerTopicName,
+            string brokerTopicBody, DateTimeOffset startTime, TimeSpan duration)
+            : base(operationId, operation, groupName, brokerTopicName, brokerTopicBody, startTime)
+        {
+            Duration = duration;
+        }
+    }
+}

src/DotNetCore.CAP/Diagnostics/EventData.Broker.ConsumeError.cs

+using System;
+
+namespace DotNetCore.CAP.Diagnostics
+{
+    public class BrokerConsumeErrorEventData : BrokerConsumeEndEventData, IErrorEventData
+    {
+        public Exception Exception { get; }
+
+        public BrokerConsumeErrorEventData(Guid operationId, string operation, string groupName,
+            string brokerTopicName, string brokerTopicBody, Exception exception, DateTimeOffset startTime, TimeSpan duration)
+            : base(operationId, operation, groupName, brokerTopicName, brokerTopicBody, startTime, duration)
+        {
+            Exception = exception;
+        }
+    }
+}

src/DotNetCore.CAP/Diagnostics/EventData.Broker.Publish.cs

+using System;
+
+namespace DotNetCore.CAP.Diagnostics
+{
+    public class BrokerPublishEventData : BrokerEventData
+    {
+        public DateTimeOffset StartTime { get; }
+
+        public BrokerPublishEventData(Guid operationId, string operation, string groupName,
+            string brokerTopicName, string brokerTopicBody, DateTimeOffset startTime)
+            : base(operationId, operation, groupName, brokerTopicName, brokerTopicBody)
+        {
+            StartTime = startTime;
+        }
+    }
+}

src/DotNetCore.CAP/Diagnostics/EventData.Broker.PublishEnd.cs

+using System;
+
+namespace DotNetCore.CAP.Diagnostics
+{
+    public class BrokerPublishEndEventData : BrokerPublishEventData
+    {
+        public TimeSpan Duration { get; }
+
+        public BrokerPublishEndEventData(Guid operationId, string operation, string groupName, string brokerTopicName,
+            string brokerTopicBody, DateTimeOffset startTime, TimeSpan duration)
+            : base(operationId, operation, groupName, brokerTopicName, brokerTopicBody, startTime)
+        {
+            Duration = duration;
+        }
+    }
+}

src/DotNetCore.CAP/Diagnostics/EventData.Broker.PublishError.cs

+using System;
+
+namespace DotNetCore.CAP.Diagnostics
+{
+    public class BrokerPublishErrorEventData : BrokerPublishEndEventData, IErrorEventData
+    {
+        public Exception Exception { get; }
+
+        public BrokerPublishErrorEventData(Guid operationId, string operation, string groupName,
+            string brokerTopicName, string brokerTopicBody, Exception exception, DateTimeOffset startTime, TimeSpan duration)
+            : base(operationId, operation, groupName, brokerTopicName, brokerTopicBody, startTime, duration)
+        {
+            Exception = exception;
+        }
+    }
+}

src/DotNetCore.CAP/Diagnostics/EventData.Broker.cs

+using System;
+
+namespace DotNetCore.CAP.Diagnostics
+{
+    public class BrokerEventData : EventData
+    {
+        public string GroupName { get; set; }
+
+        public string BrokerTopicBody { get; set; }
+
+        public string BrokerTopicName { get; set; }
+
+        public BrokerEventData(Guid operationId, string operation, string groupName, 
+            string brokerTopicName, string brokerTopicBody)
+            : base(operationId, operation)
+        {
+            GroupName = groupName;
+            BrokerTopicName = brokerTopicName;
+            BrokerTopicBody = brokerTopicBody;
+        }
+    }
+}

src/DotNetCore.CAP/Diagnostics/EventData.SubscriberInvoke.cs

+using System;
+
+namespace DotNetCore.CAP.Diagnostics
+{
+    public class SubscriberInvokeEventData : EventData
+    {
+        public DateTimeOffset StartTime { get; }
+
+        public string MethodName { get; set; }
+
+        public string SubscribeName { get; set; }
+
+        public string SubscribeGroup { get; set; }
+
+        public string ParameterValues { get; set; }
+
+        public SubscriberInvokeEventData(Guid operationId,
+            string operation,
+            string methodName, 
+            string subscribeName,
+            string subscribeGroup,
+            string parameterValues, 
+            DateTimeOffset startTime)
+            : base(operationId, operation)
+        {
+            MethodName = methodName;
+            SubscribeName = subscribeName;
+            SubscribeGroup = subscribeGroup;
+            ParameterValues = parameterValues;
+            StartTime = startTime;
+        }
+    }
+}

src/DotNetCore.CAP/Diagnostics/EventData.SubscriberInvokeEnd.cs

+using System;
+
+namespace DotNetCore.CAP.Diagnostics
+{
+    public class SubscriberInvokeEndEventData : SubscriberInvokeEventData
+    {
+        public TimeSpan Duration { get; }
+
+        public SubscriberInvokeEndEventData(Guid operationId, string operation,
+            string methodName, string subscribeName, string subscribeGroup,
+            string parameterValues, DateTimeOffset startTime, TimeSpan duration)
+            : base(operationId, operation, methodName, subscribeName, subscribeGroup, parameterValues, startTime)
+        {
+            Duration = duration;
+        }
+    }
+}

src/DotNetCore.CAP/Diagnostics/EventData.SubscriberInvokeError.cs

+using System;
+
+namespace DotNetCore.CAP.Diagnostics
+{
+    public class SubscriberInvokeErrorEventData : SubscriberInvokeEndEventData, IErrorEventData
+    {
+        public Exception Exception { get; }
+
+        public SubscriberInvokeErrorEventData(Guid operationId, string operation, string methodName,
+            string subscribeName, string subscribeGroup, string parameterValues, Exception exception,
+            DateTimeOffset startTime, TimeSpan duration) : base(operationId, operation, methodName, subscribeName,
+            subscribeGroup, parameterValues, startTime, duration)
+        {
+            Exception = exception;
+        }
+    }
+}

src/DotNetCore.CAP/Diagnostics/EventData.cs

+using System;
+
+namespace DotNetCore.CAP.Diagnostics
+{
+    public class EventData
+    {
+        public EventData(Guid operationId, string operation)
+        {
+            OperationId = operationId;
+            Operation = operation;
+        }
+
+        public Guid OperationId { get; set; }
+
+        public string Operation { get; set; }
+    }
+}

src/DotNetCore.CAP/Diagnostics/IErrorEventData.cs

+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace DotNetCore.CAP.Diagnostics
+{
+    public interface IErrorEventData
+    {
+        Exception Exception { get; }
+    }
+}