Jak używać wtrysku Autofac Dependency w MassTransit IConsume

Question

Próbuję użyć DI z moją klasą konsumencką bez powodzenia.

Moja klasa konsumentów:

public class TakeMeasureConsumer : IConsumer<TakeMeasure> 
{ 

    private IUnitOfWorkAsync _uow; 
    private IInstrumentOutputDomainService _instrumentOutputDomainService; 


    public TakeMeasureConsumer(IUnitOfWorkAsync uow, 
     IInstrumentOutputDomainService instrumentOutputDomainService) 
    { 
     _uow = uow; 
     _instrumentOutputDomainService = instrumentOutputDomainService; 
    } 


    public async Task Consume(ConsumeContext<TakeMeasure> context) 
    { 

     var instrumentOutput = Mapper.Map<InstrumentOutput>(context.Message); 

     _instrumentOutputDomainService.Insert(instrumentOutput); 
     await _uow.SaveChangesAsync(); 

    } 
} 

Kiedy chcę zarejestrować fabrykę autobusów konsument musi mieć konstruktora bez parametrów.

protected override void Load(ContainerBuilder builder) 
    { 

     builder.Register(context => 
      Bus.Factory.CreateUsingRabbitMq(cfg => 
      { 
       var host = cfg.Host(new Uri("rabbitmq://localhost/"), h => 
       { 
        h.Username("guest"); 
        h.Password("guest"); 
       }); 

       cfg.ReceiveEndpoint(host, "intrument_take_measure", e => 
       { 
        // Must be a non abastract type with a parameterless constructor.... 
        e.Consumer<TakeMeasureConsumer>(); 

       }); 

      })) 
     .SingleInstance() 
     .As<IBusControl>() 
     .As<IBus>(); 

Każda pomoc będzie mile widziane, ja naprawdę nie wiem, jak się zarejestrować konsumenta ...

Dzięki

Answer 1

Integracja z Autofac jest łatwe, istnieją metody przedłużania paczkowane MassTransit.Autofac które pomagają.

Po pierwsze, istnieje AutofacConsumerFactory, który usunie klientów z pojemnika. Można dodać do pojemnika, albo można to zarejestrować się używając:

builder.RegisterGeneric(typeof(AutofacConsumerFactory<>)) 
    .WithParameter(new NamedParameter("name", "message")) 
    .As(typeof(IConsumerFactory<>)); 

Następnie w rachunku budowniczy na autobus i otrzymać końcowy:

e.Consumer(() => context.Resolve<IConsumerFactory<TakeMeasureConsumer>()); 

Będzie to rozwiązać swoich konsumentów pojemnik.

Aktualizacja:

nowsze wersje MassTransit dodać otrzymać punkty końcowe tak:

e.Consumer<TakeMeasureConsumer>(context);