refactor

src/Cap.Consistency/Abstractions/ConsumerContext.cs

@@ -2,19 +2,20 @@
 using System.Collections.Generic;
 using System.Text;
 using System.Threading.Tasks;
+using Cap.Consistency.Infrastructure;
 
 namespace Cap.Consistency.Abstractions
 {
- 
     public class ConsumerContext
     {
-        public ConsumerContext(ConsumerExecutorDescriptor descriptor) {
+        public ConsumerContext(ConsumerExecutorDescriptor descriptor, DeliverMessage message) {
+
             ConsumerDescriptor = descriptor ?? throw new ArgumentNullException(nameof(descriptor));
+            DeliverMessage = message ?? throw new ArgumentNullException(nameof(message));
         }
 
         public ConsumerExecutorDescriptor ConsumerDescriptor { get; set; }
 
-
-     
+        public DeliverMessage DeliverMessage { get; set; }
     }
 }

src/Cap.Consistency/Abstractions/ConsumerExecutorDescriptor.cs

@@ -9,10 +9,10 @@ namespace Cap.Consistency.Abstractions
     {
         public MethodInfo MethodInfo { get; set; }
 
-        public Type ImplType { get; set; }
+        public TypeInfo ImplTypeInfo { get; set; }
 
         public TopicInfo Topic { get; set; }
 
-        public int GroupId { get; set; }
+        public string GroupId { get; set; }
     }
 }