Entity Framework Core

The TurboMediator.Persistence.EntityFramework package provides Entity Framework Core implementations for the persistence abstractions.

Installation

dotnet add package TurboMediator.Persistence.EntityFramework

Provided Implementations

Abstraction	EF Core Implementation
`ITransactionManager`	`EfCoreTransactionManager`
`IOutboxStore`	`EfCoreOutboxStore`
`IInboxStore`	`EfCoreInboxStore`
`IAuditStore`	`EfCoreAuditStore`

Registration

All at once

builder.Services.AddTurboMediator(m =>
{
    m.UseEntityFramework();
    // Registers all three EF Core implementations
});

// Or using the convenience method
builder.Services.AddTurboMediator(m =>
{
    m.WithEntityFramework();
});

Individual registration

builder.Services.AddTurboMediator(m =>
{
    m.UseEfCoreTransactions();
    m.UseEfCoreOutboxStore();
    m.UseEfCoreInboxStore();
    m.UseEfCoreAuditStore();
});

DbContext Configuration

Your DbContext needs to include the entity configurations for outbox and audit:

public class AppDbContext : DbContext
{
    public DbSet<OutboxMessage> OutboxMessages => Set<OutboxMessage>();
    public DbSet<InboxMessage> InboxMessages => Set<InboxMessage>();
    public DbSet<AuditEntry> AuditEntries => Set<AuditEntry>();

    protected override void OnModelCreating(ModelBuilder modelBuilder)
    {
        // Apply outbox and audit entity configurations
        // provided by the package
        base.OnModelCreating(modelBuilder);
    }
}

Complete Setup Example

var builder = WebApplication.CreateBuilder(args);

// Add EF Core
builder.Services.AddDbContext<AppDbContext>(options =>
    options.UseSqlServer(builder.Configuration.GetConnectionString("Default")));

// Add TurboMediator with EF Core persistence
builder.Services.AddTurboMediator(m =>
{
    m.WithEntityFramework();
    m.WithTransactionForCommands();
    m.WithOutbox();
    m.WithInbox();
    m.WithAuditForAll();
});

var app = builder.Build();

Migration

After setup, create a migration to add the outbox, inbox, and audit tables:

dotnet ef migrations add AddMediatorPersistence
dotnet ef database update

Entity Framework Core

On this page