<UnicastBusConfig>
  <MessageEndpointMappings>
    <add Messages="Messages.Persistence" Endpoint="PersisterInputQueue" />
  </MessageEndpointMappings>
</UnicastBusConfig>

protected void Application_Start(object sender, EventArgs e)
 {
     try
     {
         Bus = Configure.WithWeb()
             .SpringBuilder()
             .XmlSerializer()
             .MsmqTransport()
                 .IsTransactional(false)
                 .PurgeOnStartup(false)

public static Configure CustomSagaPersister(this Configure config, ISessionFactory sessionFactory)
{
    if (sessionFactory == null)
    {
        throw new InvalidOperationException("Session factory is needed for saga persistence.");
    }
 
    config.Configurer.RegisterSingleton<ISessionFactory>(sessionFactory);
    config.Configurer
        .ConfigureComponent<FluentSagaPersister>(ComponentCallModelEnum.Singlecall)

public class SagaFinder : IFindSagas<MySagaData>.Using<MyMessage>
{
    public MySagaData FindBy(MyMessage message)
    {
        
    }
}

public static class ExtensionMethods
{
    public static Configure FluentSagaPersister(this Configure config)
    {
        ISessionFactory sessionFactory = FluentConfig.GetFluentSessionFactory();
        config.Configurer.RegisterSingleton<ISessionFactory>(sessionFactory);
        config.Configurer.ConfigureComponent<FluentSagaPersister>(ComponentCallModelEnum.Singlecall);
 
        return config;
    }

public class FluentSagaPersister : ISagaPersister
{
    /// <summary>
    /// Injected session factory.
    /// </summary>
    public ISessionFactory SessionFactory { get; set; }
 
    #region ISagaPersister Members
 
    public void Save(ISagaEntity saga)