Autofac.Core.DependencyResolutionException
HResult = 0x80131500
Сообщение = Возникла исключительная ситуация при активации Property.Service.API.Application.Commands.AddPropertyCommandHandler.
Источник = Autofac
Трассировки стека:
в Autofac.Core.Resolving.InstanceLookup.Activate (IEnumerable 1 parameters, Object& decoratorTarget)
at Autofac.Core.Resolving.InstanceLookup.Execute()
at Autofac.Core.Resolving.ResolveOperation.GetOrCreateInstance(ISharingLifetimeScope currentOperationScope, IComponentRegistration registration, IEnumerable 1 параметры)
в Autofac.Core.Resolving.ResolveOperation.Execute (регистрация IComponentRegistration, параметры IEnumerable 1 parameters)
at Autofac.ResolutionExtensions.TryResolveService(IComponentContext context, Service service, IEnumerable 1, объект и экземпляр)
в Property.Service.API.Infrastructure.AutofacModules.MediatorModule. <> c__DisplayClass0_0.b__5 (Тип t) в C: \ Property.Service \ Property.Service.Application \ Infrastructure \ AutofacModules \ MediatorModule.cs: строка 56
в MediatR.ServiceFactoryExtensions.GetInstance [T] (фабрика ServiceFactory)
в MediatR.Internal.RequestHandlerBase.GetHandler [THandler] (фабрика ServiceFactory)
Внутреннее исключение 1:
DependencyResolutionException: ни один из конструкторов, найденных с Autofac.Core.Activators.Reflection.DefaultConstructorFinder 'для type.Property.Service.API.Application.Commands.AddPropertyCommandHandler', не может быть вызван с доступными службами и параметрами:
Невозможно разрешить параметр 'Property.Service.API.Application.IntegrationEvents.IPropertyIntegrationEventService propertyIntegrationEventService' конструктора 'Void .ctor (Property.Service.Domain.AggregatesModel.PropertyAggregate.IPropertyRepository, MediatR.IMer.Ipplication.Int.Implication.Iedition.i.Id.Id. IPropertyIntegrationEventService, Microsoft.Extensions.Logging.ILogger`1 [Property.Service.API.Application.Commands.AddPropertyCommandHandler]) '.
AddPropertyCommandHandler
public class AddPropertyCommandHandler : IRequestHandler<AddPropertyCommand, bool>
{
private readonly IPropertyRepository _propertyRepository;
private readonly IMediator _mediator;
private readonly IPropertyIntegrationEventService _propertyIntegrationEventService;
private readonly ILogger<AddPropertyCommandHandler> _logger;
public AddPropertyCommandHandler(
IPropertyRepository propertyRepository,
IMediator mediator,
IPropertyIntegrationEventService propertyIntegrationEventService,
ILogger<AddPropertyCommandHandler> logger)
{
_propertyRepository = propertyRepository ?? throw new ArgumentNullException(nameof(propertyRepository));
_mediator = mediator ?? throw new ArgumentNullException(nameof(mediator));
_logger = logger ?? throw new ArgumentNullException(nameof(logger));
_propertyIntegrationEventService = propertyIntegrationEventService;
}
public async Task<bool> Handle(AddPropertyCommand message, CancellationToken cancellationToken)
{
var propertyStartedIntegrationEvent = new PropertyStartedIntegrationEvent(message.ModifiedUserId);
await _propertyIntegrationEventService.AddAndSaveEventAsync(propertyStartedIntegrationEvent);
var property = new DomainModels.Property(message.PropertyId,message.PropertyType,message.PropertyLayout,message.PropertyPrice,message.Location,message.PropertyOwnerShip,message.PropertyFor,message.PictureUrl);
foreach (var item in message.PropertyItems)
{
property.AddOrderItem(
item.PropertyId,
item.PropertyType,
item.PropertyLayout,
item.PropertyPrice,
item.Location,
item.PropertyOwnerShip,
item.PropertyFor,
item.PictureUrl);
}
_logger.LogInformation("----- Adding Property - Property: {@Property}", property);
_propertyRepository.Add(property);
return await _propertyRepository.UnitOfWork.SaveEntitiesAsync();
}
}
MediatorModule
public class MediatorModule : Autofac.Module
{
protected override void Load(ContainerBuilder builder)
{
builder.RegisterAssemblyTypes(typeof(IMediator).GetTypeInfo().Assembly)
.AsImplementedInterfaces();
builder.RegisterAssemblyTypes(typeof(AddPropertyCommand).GetTypeInfo().Assembly)
.AsClosedTypesOf(typeof(IRequestHandler<,>));
builder
.RegisterAssemblyTypes(typeof(AddPropertyCommandValidator).GetTypeInfo().Assembly)
.Where(t => t.IsClosedTypeOf(typeof(IValidator<>)))
.AsImplementedInterfaces();
builder.Register<ServiceFactory>(context =>
{
var componentContext = context.Resolve<IComponentContext>();
return t => { object o; return componentContext.TryResolve(t, out o) ? o : null; };
});
IPropertyIntegrationEventService
public interface IPropertyIntegrationEventService
{
Task PublishEventsThroughEventBusAsync();
Task AddAndSaveEventAsync(IntegrationEvent evt);
}
PropertyIntegrationEventService
private readonly Func<DbConnection, IIntegrationeventlogservice> _integrationEventLogServiceFactory;
private readonly IEventBus _eventBus;
private readonly RealxContext _realxContext;
private readonly IntegrationEventLogContext _eventLogContext;
private readonly IIntegrationeventlogservice _eventLogService;
private readonly ILogger<PropertyIntegrationEventService> _logger;
public PropertyIntegrationEventService(IEventBus eventBus,
RealxContext realxContext,
IntegrationEventLogContext eventLogContext,
Func<DbConnection, IIntegrationeventlogservice> integrationEventLogServiceFactory,
ILogger<PropertyIntegrationEventService> logger)
{
_integrationEventLogServiceFactory = integrationEventLogServiceFactory ?? throw new ArgumentNullException(nameof(integrationEventLogServiceFactory));
_realxContext = realxContext ?? throw new ArgumentNullException(nameof(realxContext));
_eventBus = eventBus ?? throw new ArgumentNullException(nameof(eventBus));
_eventLogContext = eventLogContext ?? throw new ArgumentNullException(nameof(eventLogContext));
_logger = logger ?? throw new ArgumentNullException(nameof(logger));
}
public async Task PublishEventsThroughEventBusAsync()
{
var pendingLogEvents = await _eventLogService.RetrieveEventLogsPendingToPublishAsync();
foreach (var logEvt in pendingLogEvents)
{
_logger.LogInformation(
"----- Publishing integration event: {IntegrationEventId} from {AppName} - ({@IntegrationEvent})",
logEvt.EventId,
"PropertyService",
logEvt.IntegrationEvent);
try
{
await _eventLogService.MarkEventAsInProgressAsync(logEvt.EventId);
_eventBus.Publish(logEvt.IntegrationEvent);
await _eventLogService.MarkEventAsPublishedAsync(logEvt.EventId);
}
catch (Exception ex)
{
_logger.LogError(ex, "ERROR publishing integration event: {IntegrationEventId} from {AppName}", logEvt.EventId, "PropertyService");
await _eventLogService.MarkEventAsFailedAsync(logEvt.EventId);
}
}
}
public async Task AddAndSaveEventAsync(IntegrationEvent evt)
{
_logger.LogInformation("----- Enqueuing integration event {IntegrationEventId} to repository ({@IntegrationEvent})", evt.Id, evt);
//await _eventLogService.SaveEventAsync(evt, _realxContext.GetCurrentTransaction.GetDbTransaction());
}
Зависимость у меня есть. Зарегистрироваться
services.AddTransient<IPropertyIntegrationEventService, PropertyIntegrationEventService>();