Fluens.Messaging.SqlServer
0.9.2
dotnet add package Fluens.Messaging.SqlServer --version 0.9.2
NuGet\Install-Package Fluens.Messaging.SqlServer -Version 0.9.2
<PackageReference Include="Fluens.Messaging.SqlServer" Version="0.9.2" />
<PackageVersion Include="Fluens.Messaging.SqlServer" Version="0.9.2" />
<PackageReference Include="Fluens.Messaging.SqlServer" />
paket add Fluens.Messaging.SqlServer --version 0.9.2
#r "nuget: Fluens.Messaging.SqlServer, 0.9.2"
#:package Fluens.Messaging.SqlServer@0.9.2
#addin nuget:?package=Fluens.Messaging.SqlServer&version=0.9.2
#tool nuget:?package=Fluens.Messaging.SqlServer&version=0.9.2
Fluens.Messaging.SqlServer
SQL Server provider for Fluens.Messaging — nvarchar(max) attempt_history, dbo schema, SqlException transient-failure classification, and a startup READ_COMMITTED_SNAPSHOT guard.
Installation
dotnet add package Fluens.Messaging.SqlServer
Usage
Opt in from the AddMessaging callback — there is no separate top-level registration method:
fluensBuilder.AddMessaging(o => o.AddSqlServer());
AddSqlServer() registers SqlServerMessagingConventions as the singleton IMessagingProviderConventions
(TryAddSingleton — calling it twice, or alongside AddPostgres(), keeps whichever ran first) plus a
ReadCommittedSnapshotValidator hosted service (idempotent — repeated calls do not add a second one).
Startup schema verification
This package supplies the catalog reader (SqlServerSchemaCatalogReader, reading INFORMATION_SCHEMA) that the
Fluens.Messaging startup schema verification needs: with AddSqlServer() registered, a host whose messaging
tables do not match the installed Fluens version is refused at start with a SchemaVerificationException that
names the upgrade helper to call. The verification runs before any hosted service starts, so on a database that is
both stale and without snapshot isolation the schema error is reported first. Without a provider package there is
no catalog reader and the check is skipped. Fluens:Messaging:VerifySchemaOnStartup set to false switches it
off. See the Fluens.Messaging README.
READ_COMMITTED_SNAPSHOT startup guard
SQL Server's default READ COMMITTED isolation takes shared locks on read, which does not reproduce
PostgreSQL's MVCC read semantics the outbox/inbox fetch paths rely on. At host start,
ReadCommittedSnapshotValidator resolves every distinct module database (deduplicated by connection string)
and queries sys.databases.is_read_committed_snapshot_on. When it is false for any database, host start
aborts with OptionsException<MessagingOptions> carrying the remedy:
ALTER DATABASE [YourDatabase] SET READ_COMMITTED_SNAPSHOT ON; -- requires no other active connections
Conventions
| Convention | Value |
|---|---|
DefaultSchema |
dbo |
JsonColumnType (dead-letter attempt_history) |
nvarchar(max) |
OutboxPendingFilter |
[sent_at] IS NULL |
DeliveryPendingFilter |
[delivered_at] IS NULL AND [expired_at] IS NULL |
InboxPendingFilter |
[processed_at] IS NULL |
IngressPendingFilter |
[processed_at] IS NULL |
IsTransientFailure |
true for a SqlException whose Number is in the well-known SQL Server transient-error set (deadlock victim 1205, client/command timeout -2, connection-level failures, the Azure SQL throttling / resource-governor / optimistic-concurrency family) — anything else, including a non-SqlException, is non-transient |
The transient classification feeds the stage-1 in-memory retry gate on LaneWorker: a transient failure walks
the full two-stage retry policy, a non-transient failure (e.g. a constraint violation) skips straight to
stage-2 scheduling.
License
This project is licensed under the MIT License.
| Product | Versions Compatible and additional computed target framework versions. |
|---|---|
| .NET | net10.0 is compatible. net10.0-android was computed. net10.0-browser was computed. net10.0-ios was computed. net10.0-maccatalyst was computed. net10.0-macos was computed. net10.0-tvos was computed. net10.0-windows was computed. |
-
net10.0
- Fluens (>= 0.9.2)
- Fluens.Messaging (>= 0.9.2)
- Microsoft.EntityFrameworkCore.Relational (>= 10.0.13)
- Microsoft.EntityFrameworkCore.SqlServer (>= 10.0.13)
- Microsoft.Extensions.Configuration.Abstractions (>= 10.0.13)
- Microsoft.Extensions.Configuration.Binder (>= 10.0.13)
- Microsoft.Extensions.DependencyInjection (>= 10.0.13)
- Microsoft.Extensions.DependencyInjection.Abstractions (>= 10.0.13)
- Microsoft.Extensions.Hosting.Abstractions (>= 10.0.13)
- Microsoft.Extensions.Logging (>= 10.0.13)
- Microsoft.Extensions.Logging.Abstractions (>= 10.0.13)
- Microsoft.Extensions.Options.ConfigurationExtensions (>= 10.0.13)
- Microsoft.IdentityModel.Tokens (>= 8.23.0)
- Scrutor (>= 7.0.0)
- System.Security.Cryptography.Pkcs (>= 10.0.13)
NuGet packages
This package is not used by any NuGet packages.
GitHub repositories
This package is not used by any popular GitHub repositories.
| Version | Downloads | Last Updated |
|---|---|---|
| 0.9.2 | 0 | 10/21/2026 |
| 0.9.1 | 89 | 10/13/2026 |
| 0.9.0 | 79 | 10/13/2026 |
| 0.8.7 | 80 | 10/12/2026 |
| 0.8.6 | 84 | 10/12/2026 |
| 0.8.5 | 85 | 10/7/2026 |
| 0.8.4 | 81 | 10/6/2026 |
| 0.8.3 | 88 | 10/6/2026 |
| 0.8.2 | 93 | 10/5/2026 |
| 0.8.1 | 107 | 9/15/2026 |
| 0.8.0 | 101 | 9/15/2026 |
| 0.7.11 | 191 | 9/15/2026 |
| 0.7.10 | 106 | 9/13/2026 |
| 0.7.9 | 108 | 9/11/2026 |
| 0.7.8 | 110 | 9/10/2026 |
| 0.7.7 | 110 | 9/10/2026 |