Autofac & MassTransit - Registre Consumer ObjectDisposedException

Question

Contexte: ASP.NET Core App (1.1).

J'essaie de résoudre l'IRepository que j'ai déjà enregistré quand j'ai besoin d'une instance de consommateur, mais il semble que je reçois une ObjectDisposedException.

J'ai créé une méthode de fabrication de bus automatique est activée quand je l'appelle méthode .Build() du ContainerBuilder.

public IServiceProvider ConfigureServices(IServiceCollection services) 
{ 
    var containerBuilder = new ContainerBuilder(); 
    containerBuilder.RegisterType<EventTypeResolver>().As<IEventTypeResolver>(); 
    containerBuilder.RegisterType<Repository>().As<IRepository>(); 
    containerBuilder.Register(c => EventStoreConnectionFactory.Create()) 
          .As<IEventStoreConnection>(); 
    containerBuilder.Register(BusFactoryMethod).AsSelf().SingleInstance().AutoActivate(); 
    containerBuilder.Populate(services); 
    return new AutofacServiceProvider(containerBuilder.Build()); 
} 

BusFactoryMethod ressemble à ceci:

private IBusControl BusFactoryMethod(IComponentContext componentContext) 
{ 
    var busControl = BusConfigurator.Instance.ConfigureBus((cfg, host) => 
      { 
       cfg.ReceiveEndpoint(host, RabbitMQConstants.UserManagementQueue, e => 
       { 
        e.Consumer(() => new CreateUserCommandConsumer(componentContext.Resolve<IRepository>())); 
       }); 
      }); 
    busControl.Start(); 
    return busControl; 
} 

Answer 1

J'ai donc trouvé un paquet MassTransit.AutofacIntegration qui a déjà une méthode RegisterConsumers.

Ensuite, j'ai utilisé la méthode RegisterGeneric d'Autofac afin d'obtenir une durée de vie par message.

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

Et a fini avec les éléments suivants Module:

public class DefaultModule : Autofac.Module 
     { 
      protected override void Load(ContainerBuilder containerBuilder) 
      { 
       containerBuilder.Register(c => new EventTypeResolver(typeof(DefaultModule).GetTypeInfo().Assembly)).As<IEventTypeResolver>(); 
       containerBuilder.Register(c => EventStoreConnectionFactory.Create()) 
           .As<IEventStoreConnection>(); 
       containerBuilder.RegisterType<Repository>().As<IRepository>(); 
       containerBuilder.RegisterConsumers(typeof(DefaultModule).GetTypeInfo().Assembly).AsSelf().AsImplementedInterfaces(); 
       containerBuilder.RegisterGeneric(typeof(AutofacConsumerFactory<>)) 
          .WithParameter(new NamedParameter("name", "message")) 
          .As(typeof(IConsumerFactory<>)) 
          .InstancePerLifetimeScope(); 
       containerBuilder.Register((c) => 
       { 
        var busControl = BusConfigurator.Instance.ConfigureBus((cfg, host) => 
        { 
         ConfigureEndPoints(cfg, host, c); 
        }); 
        busControl.Start(); 
        return busControl; 
       }).SingleInstance().AutoActivate(); 
      } 

      private void ConfigureEndPoints(IRabbitMqBusFactoryConfigurator cfg, IRabbitMqHost host, IComponentContext context) 
      { 
       cfg.ReceiveEndpoint(host, RabbitMQConstants.UserManagementQueue, e => 
       { 
        e.Consumer(context.Resolve<IConsumerFactory<CreateUserCommandConsumer>>()); 
       }); 
      } 
     } 

méthode ConfigureServices ressemble maintenant à ceci:

public IServiceProvider ConfigureServices(IServiceCollection services) 
     { 
      var containerBuilder = new ContainerBuilder(); 
      containerBuilder.RegisterModule<DefaultModule>(); 
      containerBuilder.Populate(services); 
      return new AutofacServiceProvider(containerBuilder.Build()); 
     }