Autofac＆MassTransit - Consumer ObjectDisposedExceptionを登録します。

Question

コンテキスト：ASP.NET Core App（1.1）。

私はコンシューマーインスタンスが必要なときに既に登録したIRepositoryを解決しようとしますが、ObjectDisposedExceptionが表示されるようです。

私は私がContainerBuilderの.Build()メソッドを呼び出したときに自動アクティブバスファクトリメソッドを作成しました。

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次のようになります。

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

だから私はすでにRegisterConsumersメソッドを持つパッケージMassTransit.AutofacIntegrationを見つけました。

次に、メッセージあたりの有効期間を得るために、私はAutofacのRegisterGenericメソッドを使用しました。

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

そして、次のModuleになってしまった：あなたは、過渡依存関係として、あなたの `IRepository`を登録している

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