Fluens.Messaging.SqlServer
0.7.10
dotnet add package Fluens.Messaging.SqlServer --version 0.7.10
NuGet\Install-Package Fluens.Messaging.SqlServer -Version 0.7.10
<PackageReference Include="Fluens.Messaging.SqlServer" Version="0.7.10" />
<PackageVersion Include="Fluens.Messaging.SqlServer" Version="0.7.10" />
<PackageReference Include="Fluens.Messaging.SqlServer" />
paket add Fluens.Messaging.SqlServer --version 0.7.10
#r "nuget: Fluens.Messaging.SqlServer, 0.7.10"
#:package Fluens.Messaging.SqlServer@0.7.10
#addin nuget:?package=Fluens.Messaging.SqlServer&version=0.7.10
#tool nuget:?package=Fluens.Messaging.SqlServer&version=0.7.10
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).
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.7.10)
- Fluens.Messaging (>= 0.7.10)
- Microsoft.EntityFrameworkCore.SqlServer (>= 10.0.12)
NuGet packages
This package is not used by any NuGet packages.
GitHub repositories
This package is not used by any popular GitHub repositories.