¿Cómo puedo inyectar múltiples repositorios en un manejador de mensajes NServicebus?

Question

que utilizar los siguientes:

public interface IRepository<T> 
{ 
    void Add(T entity); 
} 

public class Repository<T> 
{ 
    private readonly ISession session; 

    public Repository(ISession session) 
    { 
    this.session = session; 
    } 

    public void Add(T entity) 
    { 
    session.Save(entity); 
    } 
} 

public class SomeHandler : IHandleMessages<SomeMessage> 
{ 
    private readonly IRepository<EntityA> aRepository; 
    private readonly IRepository<EntityB> bRepository; 

    public SomeHandler(IRepository<EntityA> aRepository, IRepository<EntityB> bRepository) 
    { 
    this.aRepository = aRepository; 
    this.bRepository = bRepository; 
    } 

    public void Handle(SomeMessage message) 
    { 
    aRepository.Add(new A(message.Property); 
    bRepository.Add(new B(message.Property); 
    } 
} 

public class MessageEndPoint : IConfigureThisEndpoint, AsA_Server, IWantCustomInitialization 
{ 
    public void Init() 
    { 
     ObjectFactory.Configure(config => 
     { 
      config.For<ISession>() 
       .CacheBy(InstanceScope.ThreadLocal) 
       .TheDefault.Is.ConstructedBy(ctx => ctx.GetInstance<ISessionFactory>().OpenSession()); 
      config.ForRequestedType(typeof(IRepository<>)) 
       .TheDefaultIsConcreteType(typeof(Repository<>)); 
    } 
} 

Mi problema con el almacenamiento ThreadLocal es, es que la misma sesión se utiliza durante todo el subproceso de la aplicación. Descubrí esto cuando vi que no se borraba el primer nivel de caché. Lo que quiero es usar una nueva instancia de sesión, antes de cada llamada a IHandleMessages <> .Handle. ¿Cómo puedo hacer esto con structuremap? ¿Tengo que crear un módulo de mensaje?

Answer 1

Tiene razón en que la misma sesión se usa para todas las solicitudes al mismo hilo. Esto se debe a que NSB no crea nuevos subprocesos para cada solicitud. La solución alternativa es agregar un modo de caché personalizado y borrarlo cuando se completa el manejo de mensajes.

1.Extend el ciclo de vida de almacenamiento de hilo y engancharlo hasta un módulo de un mensaje

public class NServiceBusThreadLocalStorageLifestyle : ThreadLocalStorageLifecycle, IMessageModule 
{ 

    public void HandleBeginMessage(){} 

    public void HandleEndMessage() 
    { 
     EjectAll(); 
    } 

    public void HandleError(){} 
} 

2.Configure su StructureMap de la siguiente manera:

For<<ISession>> 
.LifecycleIs(new NServiceBusThreadLocalStorageLifestyle()) 
... 

Espero que esto ayude!