fixed consumer method injection context bug. (#34)

dotnetcore · Aug 17, 2017 · 8c5da12 · 8c5da12
1 parent 75a3833
commit 8c5da12
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/src/DotNetCore.CAP/Internal/ConsumerInvokerFactory.cs b/src/DotNetCore.CAP/Internal/ConsumerInvokerFactory.cs
@@ -1,5 +1,6 @@
 using System;
 using DotNetCore.CAP.Abstractions;
+using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Logging;
 
 namespace DotNetCore.CAP.Internal
@@ -22,12 +23,15 @@ public class ConsumerInvokerFactory : IConsumerInvokerFactory
 
         public IConsumerInvoker CreateInvoker(ConsumerContext consumerContext)
         {
-            var context = new ConsumerInvokerContext(consumerContext)
+            using(var scope = _serviceProvider.CreateScope())
             {
-                Result = new DefaultConsumerInvoker(_logger, _serviceProvider, _modelBinderFactory, consumerContext)
-            };
+                var context = new ConsumerInvokerContext(consumerContext)
+                {
+                    Result = new DefaultConsumerInvoker(_logger, scope.ServiceProvider, _modelBinderFactory, consumerContext)
+                };
 
-            return context.Result;
+                return context.Result;
+            }
         }
     }
 }