Commit 63d8354a authored by yangxiaodong's avatar yangxiaodong

refactor

parent e216564f
...@@ -11,24 +11,20 @@ namespace Cap.Consistency.Internal ...@@ -11,24 +11,20 @@ namespace Cap.Consistency.Internal
{ {
private readonly ILogger _logger; private readonly ILogger _logger;
private readonly IServiceProvider _serviceProvider; private readonly IServiceProvider _serviceProvider;
private readonly ObjectMethodExecutor _executor;
public ConsumerInvokerFactory( public ConsumerInvokerFactory(
ILoggerFactory loggerFactory, ILoggerFactory loggerFactory,
IServiceProvider serviceProvider, IServiceProvider serviceProvider) {
ObjectMethodExecutor executor) {
_logger = loggerFactory.CreateLogger<ConsumerInvokerFactory>(); _logger = loggerFactory.CreateLogger<ConsumerInvokerFactory>();
_serviceProvider = serviceProvider; _serviceProvider = serviceProvider;
_executor = executor;
} }
public IConsumerInvoker CreateInvoker(ConsumerContext consumerContext) { public IConsumerInvoker CreateInvoker(ConsumerContext consumerContext) {
var context = new ConsumerInvokerContext(consumerContext); var context = new ConsumerInvokerContext(consumerContext);
context.Result = new ConsumerInvoker(_logger, _serviceProvider, context.Result = new ConsumerInvoker(_logger, _serviceProvider, consumerContext);
consumerContext, _executor);
return context.Result; return context.Result;
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment