Getting Started
Architecture
Transports
Persistence
ServiceInsight
ServicePulse
ServiceControl
Monitoring
Samples

Transactional Session with DynamoDB Persistence

NuGet Package: NServiceBus.Persistence.DynamoDB.TransactionalSession (1.x)
Target Version: NServiceBus 8.x

In order to use the transactional session feature with DynamoDB persistence, add a reference to the NServiceBus.Persistence.DynamoDB.TransactionalSession NuGet package.

Configuration

To enable the transactional session feature:

var persistence = config.UsePersistence<DynamoPersistence>();
persistence.EnableTransactionalSession();

Opening a session

To open a DynamoDB transactional session:

using var childScope = serviceProvider.CreateScope();
var session = childScope.ServiceProvider.GetService<ITransactionalSession>();
await session.Open(new DynamoOpenSessionOptions());

// use the session

await session.Commit();

Transaction usage

Message and database operations made with the transactional session are committed together once the session is committed:

await session.Open(new DynamoOpenSessionOptions());

// add messages to the transaction:
await session.Send(new MyMessage());

// access the database:
var dynamoSession = session.SynchronizedStorageSession.DynamoPersistenceSession();

await session.Commit();

See the Cosmos DB persistence transactions documentation for further details about using the transaction.

Related Articles