使用Autofac在NServiceBus中进行NHibernate会话管理

Question

Andreas Ohlund关于如何使用Structuremap来连接NHibernate会话以使其自动登记NSB事务，有一篇出色的文章here。

有没有人知道是否有可能实现与Autofac相同？

Answer 1

我被一个同事给出的awnser

public class NHibernateMessageModule : IMessageModule 
{ 
    /// <summary> 
    /// Injected SessionManager. 
    /// </summary> 
    public ISessionManager SessionManager { get; set; } 

    public void HandleBeginMessage() 
    { 
     //this session need for NServiceBus and for us 
     ThreadStaticSessionContext.Bind(SessionManager.OpenSession()); //CurrentSessionContext or ThreadStaticSessionContext 
    } 

    public void HandleEndMessage() 
    { 
     SessionManager.Session.Flush(); 
    } 

    public void HandleError() 
    { 
    } 
} 

公共接口ISessionManager { 的Isession会议{获得; } ISession OpenSession（）; bool IsSessionOpened {get; } void CloseSession（）; }

public class NHessionSessionManager：ISessionManager { private ISessionFactory _sessionFactory; private ISession _session;

public ISession Session 
    { 
     get { return _session; } 
     private set { _session = value; } 
    } 

    public SchemaExport SchemaExport { get; set; } 


    public NHibernateSessionManager(ISessionFactory sessionFactory) 
    { 
     _sessionFactory = sessionFactory; 
    } 

    public bool IsSessionOpened 
    { 
     get { return Session != null && Session.IsOpen; } 
    } 

    public ISession OpenSession() 
    { 
     if(Session == null) 
     { 
      Session = _sessionFactory.OpenSession(); 
      if (SchemaExport != null) 
       SchemaExport.Execute(true, true, false, Session.Connection, null); 
     } 
     return Session; 
    } 

    public void CloseSession() 
    { 
     if (Session != null && Session.IsOpen) 
     { 
      Session.Flush(); 
      Session.Close(); 
     } 
     Session = null; 
    } 
} 

Answer 2

您的操作与您在提及的说明中完全相同，但选择了其中一种Autofac lifescopes。如果你有参与，您希望您的会话将被注入消息处理其他类，使用InstancePerLifetimeScope这样

public class EndpointConfig : IConfigureThisEndpoint, AsA_Publisher, IWantCustomInitialization 
{ 

    public void Init() 
    { 
     var builder = new ContainerBuilder(); 
     builder.Register(s => SessionFactory.CreateSessionFactory()).As<ISessionFactory>().SingleInstance(); 
     builder.Register(x => x.Resolve<ISessionFactory>().OpenSession()).As<ISession>().InstancePerLifetimeScope(); 

     var container = builder.Build(); 
     Configure.With().AutofacBuilder(container); 
    } 

} 

您也可以注册，你需要你的NSB范围内的任何其他的依赖，你一定会很由于使用了子容器而被实例化和正确设置。