Конфигурация NServiceBus с пользовательским контейнером

Question

Я пытаюсь повторно использовать регистрацию услуг в сборке, которую я использую несколькими службами в своем решении. Я следую примеру from the NServiceBus website для реализации решения. Следуя этому, если я не добавлю интерфейс IWantCustomInitialization, мой метод Init (и реализация контейнера IoC), похоже, не функционирует. Когда у меня реализован этот интерфейс, я получаю исключения (перечисленные в ответах на вопросы here и here). Я не могу заставить его работать, что исключений нет, и зависимости в моем MessageHandler заполняются должным образом. Вот моя текущая реализация EndpointConfig.

[EndpointSLA("00:00:30")] 
public class EndpointConfig : IConfigureThisEndpoint, AsA_Server, UsingTransport<Msmq>, INeedInitialization { 
    public void Init() { 
     Configure.With().ObjectBuilderAdapter(); 
    } 
} 
public class ObjectBuilderAdapter : IContainer { 
    readonly IDependencyInjector injector; 

    public ObjectBuilderAdapter(IDependencyInjectionBuilder dependencyInjectionBuilder) { 
     injector = dependencyInjectionBuilder.Create(); //This method does all the common service registrations that I am trying to re-use 
     //injector.RegisterType<ExtractIncomingPrincipal, PrincipalExtractor>(); 
    } 

    public void Dispose() { 
     injector.Dispose(); 
    } 

    public object Build(Type typeToBuild) { 
     return injector.Resolve(typeToBuild); 
    } 

    public IContainer BuildChildContainer() { 
     return new ObjectBuilderAdapter(new DependencyInjectorBuilder()); 
    } 

    public IEnumerable<object> BuildAll(Type typeToBuild) { 
     return injector.ResolveAll(typeToBuild); 
    } 

    public void Configure(Type component, DependencyLifecycle dependencyLifecycle) { 
     injector.RegisterType(component); 
    } 

    public void Configure<T>(Func<T> component, DependencyLifecycle dependencyLifecycle) { 
     injector.RegisterType(component); 
    } 

    public void ConfigureProperty(Type component, string property, object value) { 
     if (injector is AutofacDependencyInjector) { 
      ((AutofacDependencyInjector)injector).ConfigureProperty(component, property, value); 
     } else { 
      Debug.WriteLine("Configuring {0} for property {1} but we don't handle this scenario.", component.Name, property); 
     } 
    } 

    public void RegisterSingleton(Type lookupType, object instance) { 
     injector.RegisterInstance(lookupType, instance); 
    } 

    public bool HasComponent(Type componentType) { 
     return injector.IsRegistered(componentType); 
    } 

    public void Release(object instance) { } 
} 

общественного Extensions статического класса { общественности статической Настройки ObjectBuilderAdapter (это настройка конфигурации) { ConfigureCommon.With (конфигурации, новый ObjectBuilderAdapter (новый DependencyInjectorBuilder())); return config; } }

Примечание: Когда я использую интерфейс INeedInitialization, я получаю исключение ComponentNotRegisteredException, когда он ищет IStartableBus.

Answer 1

Когда вы пытаетесь заменить встроенный контейнер, вам необходимо реализовать IWantCustomInitialization в том же классе, который реализует IConfigureThisEndpoint.

Вы можете использовать свой собственный контейнер и зарегистрировать все свои типы там и указать NSB, чтобы использовать этот контейнер.

Например:

public class EndpointConfig : IConfigureThisEndpoint, AsA_Server, IWantCustomInitialization 
{ 
    public void Init() 
    { 
     var container = new ContainerBuilder().Build(); 
     Configure.With() 
      .AutofacBuilder(container); 
    } 
}