Yautbox.Mysql 1.1.1

Yautbox.Mysql

MySQL infrastructure provider for Yautbox. It stores outbox messages in MySQL, applies schema migrations on startup, and supports distributed locks for sequential execution.

Features

• MySQL storage with schema migrations
• Distributed lock for ExecutionPolicy.Sequential
• Configurable schema name and JSON serialization
• Cleanup batching for safe-deleted records

Installation

NuGet (if published):

dotnet add package Yautbox.Mysql

From source:

dotnet add <your-app>.csproj reference src/Yautbox.Mysql/Yautbox.Mysql.csproj

Quick start

using Microsoft.Extensions.DependencyInjection;
using Yautbox.Extensions.Ioc;
using Yautbox.Mysql.Extensions;

services.AddOutbox(builder => builder.UseMysql(
 connectionString: "Server=localhost;Database=yautbox;User ID=root;Password=pass;"));

services.AddOutboxHandler<OrderPlaced, OrderPlacedHandler>();

Options

MysqlStoreOptions:

• SchemaName (default: "outbox")
• CleanupBatchSize (default: 1000)
• ConfigureJsonOptions (customize JsonSerializerOptions)

Example:

using System.Text.Json;
using Yautbox.Mysql.Extensions;
using Yautbox.Mysql.Extensions.Configurator;

services.AddOutbox(builder => builder.UseMysql(
 connectionString: "...",
 options: new MysqlStoreOptions
 {
 SchemaName = "messaging",
 CleanupBatchSize = 2000,
 ConfigureJsonOptions = (json, _) => json.PropertyNamingPolicy = JsonNamingPolicy.CamelCase
 }));

Connection factory

If you need custom connection creation (for example, Azure SQL with custom tokens), register your own factory and use the generic overload:

using Yautbox.Mysql.Extensions;
using Yautbox.Mysql.Infrastructure.Database;

public sealed class MyConnectionFactory : IOutboxConnectionFactory
{
 public string GetConnectionString() => "...";
 public Task<DbConnection> GetConnectionAsync(CancellationToken ct) => /* ... */;
}

services.AddOutbox(builder => builder.UseMysql<MyConnectionFactory>());

Migrations and readiness

This provider runs FluentMigrator migrations on startup and waits for readiness before handlers begin polling. The database user must have permissions to create schemas and tables.

Notes

• ExecutionPolicy.Sequential uses a MySQL distributed lock to ensure single active processing per identifier.
• DeletePolicy.Safe marks records as deleted; cleanup is performed by the background cleaner when BackupInterval is set.