0

私はNHibernateでNServiceBusを使用しており、独自のプロセスでバスをホストしています。私が使用している構成は次のとおりです。

Configure.ScaleOut(s => s.UseSingleBrokerQueue());
        Configure.Transactions.Enable();
        Configure.Features.Enable<Sagas>();
        Configure.Serialization.Xml();

        return
            Configure.With()
                     .DefaultBuilder()
                     .DefiningCommandsAs(type => type.Namespace != null && type.Namespace.EndsWith("Contracts.Commands"))
                     .DefiningEventsAs(type => type.Namespace != null && type.Namespace.EndsWith("Contracts.Events"))
                     .DefiningMessagesAs(type => type.Namespace != null && type.Namespace.EndsWith("Contracts.Messages"))
                     .RijndaelEncryptionService()
                     .UseTransport<RabbitMQ>()
                     .PurgeOnStartup(false)
                     .UnicastBus()
                     .RunHandlersUnderIncomingPrincipal(false)
                     .ImpersonateSender(false)
                     .LoadMessageHandlers()
                     .UseNHibernateSubscriptionPersister()
                     .UseNHibernateSagaPersister()
                     .UseNHibernateTimeoutPersister()
                     .DisableTimeoutManager()
                     .CreateBus()
                     .Start
                (() => {
                     Configure.Instance.LicensePath(Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "NServiceBus-Licence.xml"));
                     Configure.Instance.ForInstallationOn<Windows>().Install();
                 });

と：

<connectionStrings>
    <add name="NServiceBus/Transport" connectionString="host=localhost" />
    <add name="NServiceBus/Persistence" connectionString="Data Source=.\SQLEXPRESS;Initial Catalog=testdb;Persist Security Info=True; Connect Timeout=200; Pooling=True; Max Pool Size=5000; Async=true; Integrated Security=SSPI;" providerName="System.Data.SqlClient" />
</connectionStrings>
<appSettings>
    <add key="NServiceBus/Persistence/NHibernate/dialect" value="NHibernate.Dialect.MsSql2012Dialect" />
    <add key="NServiceBus/Persistence/NHibernate/connection.provider" value="NHibernate.Connection.DriverConnectionProvider" />
    <add key="NServiceBus/Persistence/NHibernate/connection.driver_class" value="NHibernate.Driver.Sql2008ClientDriver" />
</appSettings>

この構成により、SQL Server データベースに、サガで指定したフィールドを使用してサガのテーブルが作成されます。これは素晴らしいことです。

しかし、Saga が実行されて完了すると、NServiceBus はレコードを saga テーブルに挿入していないように見えます。

テーブルはありますが、データはありません。

これは予想されるべきですか？サガが正常に完了した後、NServiceBus は永続的にサガ エントリを削除しますか?

4

1 に答える 1

1

私自身の質問に対する答えはyesです。

サガが完了した後、NServiceBus はサガ データ テーブルのエントリを削除します。

于 2014-09-23T12:07:07.030 に答える