Come utilizzare Autofac Dipendenza iniezione in MassTransit IConsume

Question

Sto provando a utilizzare DI con la mia classe consumer senza successo.

La mia classe di consumatori:

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(); 

    } 
} 

Quando voglio registrare la fabbrica di autobus il consumatore deve avere un costruttore senza parametri.

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>(); 

Qualsiasi aiuto sarebbe apprezzato, io davvero non so come registrare il mio comportamento dei ...

Grazie

Answer 1

Integrazione con Autofac è facile, ci sono metodi di estensione nel pacchetto MassTransit.Autofac che aiuta.

In primo luogo, c'è uno AutofacConsumerFactory che risolverà i vostri consumatori dal contenitore. È possibile aggiungere questo al contenitore, oppure è possibile registrarsi da soli utilizzando:

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

Poi, nella dichiarazione del costruttore per il bus e ricevere endpoint:

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

Questo sarà quindi risolvere i vostri consumatori Il container.

Aggiornamento:

Per le versioni più recenti di MassTransit aggiungere ricevere endpoint come questo:

e.Consumer<TakeMeasureConsumer>(context);