Stratara.Outbox.AzureServiceBus
4.4.6
Prefix Reserved
dotnet add package Stratara.Outbox.AzureServiceBus --version 4.4.6
NuGet\Install-Package Stratara.Outbox.AzureServiceBus -Version 4.4.6
<PackageReference Include="Stratara.Outbox.AzureServiceBus" Version="4.4.6" />
<PackageVersion Include="Stratara.Outbox.AzureServiceBus" Version="4.4.6" />
<PackageReference Include="Stratara.Outbox.AzureServiceBus" />
paket add Stratara.Outbox.AzureServiceBus --version 4.4.6
#r "nuget: Stratara.Outbox.AzureServiceBus, 4.4.6"
#:package Stratara.Outbox.AzureServiceBus@4.4.6
#addin nuget:?package=Stratara.Outbox.AzureServiceBus&version=4.4.6
#tool nuget:?package=Stratara.Outbox.AzureServiceBus&version=4.4.6
Stratara.Outbox.AzureServiceBus
Derived. The behaviour described here is specified under
openspec/specs/. Those specifications are the source; this page explains and illustrates them.
License: MIT.
Azure Service Bus implementation of Stratara.Abstractions.Messaging.IMessageBus. Publishes JSON-serialized messages to topics and exposes a subscription helper that wires up a Service Bus processor with per-message exception classification:
- success →
CompleteMessageAsync ConcurrencyException→AbandonMessageAsyncuntilMessageRetry:MaxConflictRequeuesredeliveries (default 100) have not resolved it, thenDeadLetterMessageAsyncwith reasonconflict- any other exception →
AbandonMessageAsyncuntilMessageRetry:MaxDeliveryAttemptsdeliveries (default 3) have failed, thenDeadLetterMessageAsyncwith reasonfailureand the exception in the description
The subscription's own MaxDeliveryCount must leave room for the bounds; a subscription created with Service Bus defaults allows 10 deliveries. Where the host can read the subscription, the bus lowers the bounds for it to fit and logs 108_111.
System-level errors (connection drops, auth failures) arrive via ProcessErrorAsync and are logged; the Service Bus client owns the reconnect / retry policy for those.
A subscription that stops closes its processor, which takes no further message and waits for its running handler — as long as the host's shutdown timeout allows while the application stops, twenty seconds otherwise; the host waits for that before it counts as stopped. A handler that gives up because the subscription stops has its message abandoned rather than dead-lettered by the framework; the broker counts that delivery like any other. A handler's outcome is settled whatever the subscription's own cancellation says, and a handler that failed because its save committed but could not publish has its message completed, not delivered again.
Install
dotnet add package Stratara.Outbox.AzureServiceBus
Register the bus in your DI composition — one call wires the ServiceBusClient, the envelope
options and the IMessageBus implementation:
// Connection string:
builder.Services.AddAzureServiceBus(builder.Configuration.GetConnectionString("ServiceBus")!);
// Or, preferred in Azure — managed identity, no secret in configuration:
builder.Services.AddAzureServiceBusWithManagedIdentity("my-namespace.servicebus.windows.net");
The AzureServiceBusBus implementation is internal; register it through these extensions rather
than by naming the type.
The explicitly-chosen transport wins.
AddAzureServiceBusreplaces theIMessageBusregistration, so it takes effect even when the RabbitMQ umbrella (builder.AddMessaging(), which the worker composites call) already claimed the slot. Still use one transport per host — calling both is a configuration smell — but an explicitAddAzureServiceBuswill no longer be a silent no-op behind a composite.
Notes
Pre-3.0 this implementation lived inside Stratara.Outbox.RabbitMQ. As of 3.0 the two transports are separate packages so a consumer who only wants RabbitMQ does not drag the Azure Service Bus SDK into the dependency tree (and vice versa).
| 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
- Azure.Identity (>= 1.21.0)
- Azure.Messaging.ServiceBus (>= 7.20.2)
- Microsoft.Extensions.DependencyInjection.Abstractions (>= 10.0.11)
- Microsoft.Extensions.Hosting.Abstractions (>= 10.0.11)
- Microsoft.Extensions.Logging.Abstractions (>= 10.0.11)
- Microsoft.Extensions.Options (>= 10.0.11)
- Microsoft.Extensions.Options.ConfigurationExtensions (>= 10.0.11)
- Stratara.Abstractions (>= 4.4.6)
- Stratara.Shared (>= 4.4.6)
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 |
|---|---|---|
| 4.4.6 | 0 | 10/22/2026 |
| 4.4.5 | 88 | 10/14/2026 |
| 4.4.4 | 91 | 10/10/2026 |
| 4.4.3 | 95 | 10/10/2026 |
| 4.4.2 | 100 | 10/2/2026 |
| 4.4.1 | 96 | 9/29/2026 |
| 4.4.0 | 96 | 9/27/2026 |
| 4.3.1 | 104 | 9/25/2026 |
| 4.3.0 | 102 | 9/23/2026 |
| 4.2.0 | 113 | 9/18/2026 |
| 4.1.1 | 106 | 9/16/2026 |
| 4.1.0 | 97 | 9/16/2026 |
| 4.0.4 | 113 | 9/14/2026 |
| 4.0.3 | 111 | 9/3/2026 |
| 4.0.2 | 116 | 9/3/2026 |
| 4.0.1 | 105 | 9/2/2026 |
| 4.0.0 | 109 | 8/31/2026 |
| 4.0.0-preview.1 | 77 | 8/31/2026 |
| 3.4.0 | 112 | 8/28/2026 |
| 3.3.0 | 110 | 8/25/2026 |
A host on the Orleans execution model can now wait until a projection has applied what it committed, instead of
reading its read model and hoping the projection is through. Additive; no schema change and no migration.
### Added
- **`IProjectionProgress`** (`Stratara.Abstractions`), registered by `AddStrataraProjectionGrains()`.
`MarkAsync()` returns a `StoreMark` that covers every entry committed at the time of the call, in every partition
— on PostgreSQL also an entry that committed while another write was still open. `WaitAsync(projection, mark,
timeout)`, with the projection named by its type or its framework name, answers with a `ProjectionWaitResult`:
`Reached` only once the projection has applied every entry the mark covers; otherwise, at the limit, `Stalled`,
`Suspended` or `TimedOut` with the partitions behind; `MarkNotApplicable` at once for a mark taken under another
reader or partition count. A rebuild or a full replay during a wait is waited through; an unknown projection is
refused. See *Read your own write* in the projection guide.
- **`ICommittedPositionReader.CommittedHeadAsync`**, the highest position the store shows as committed. The default
answers `HeadAsync`; the native PostgreSQL reader answers it without the horizon its head is held back to. A
reader of your own that holds its head back overrides it.
### Upgrade notes
- Adopt the wait once every silo runs this release: a silo of an earlier version does not answer it, and a wait
whose partition lives there fails with the grain call's error.