Provides Azure Storage Tables-based saga storage implementation for Rebus.
You can configure the table-based saga storage like this:
Configure.With(...)
.(...)
.Sagas(d => d.StoreInAzureTables(storageConnectionString, "tableName"))
.Start();
Configure.With(...)
.(...)
.Sagas(d => d.StoreInAzureTables(endpoint, new DefaultAzureCredential(includeInteractiveCredentials: true), "tableName"))
.Start();
If you want to add different tables for each SagaDataType you can let the framework handles this. (create of tables by the process must be possible)
Configure.With(...)
.(...)
.Sagas(d => d.StoreInAzureTables(storageConnectionString, automaticallyGenerateClients: true))
.Start();
Or you can define them your self. The tableName passed in the StoreInAzureTables servers as default table (used when no tableClient for the SagaDataType is found.)
Configure.With(...)
.(...)
.Sagas(d => {
d.StoreInAzureTables(storageConnectionString, "default");
d.RegisterTableClient<SagaData>(storageConnectionString, "tableName");
d.RegisterTableClient<SagaData2>(storageConnectionString, "tableName2");
})
.Start();