Runax.Messaging.Transports.Azure.EventHubs 2.0.0

.NET 10.0

dotnet add package Runax.Messaging.Transports.Azure.EventHubs --version 2.0.0

NuGet\Install-Package Runax.Messaging.Transports.Azure.EventHubs -Version 2.0.0

This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package.

<PackageReference Include="Runax.Messaging.Transports.Azure.EventHubs" Version="2.0.0" />

For projects that support PackageReference, copy this XML node into the project file to reference the package.

<PackageVersion Include="Runax.Messaging.Transports.Azure.EventHubs" Version="2.0.0" />
                    

                            Directory.Packages.props

<PackageReference Include="Runax.Messaging.Transports.Azure.EventHubs" />
                    

                            Project file

For projects that support Central Package Management (CPM), copy this XML node into the solution Directory.Packages.props file to version the package.

paket add Runax.Messaging.Transports.Azure.EventHubs --version 2.0.0

The NuGet Team does not provide support for this client. Please contact its maintainers for support.

#r "nuget: Runax.Messaging.Transports.Azure.EventHubs, 2.0.0"

#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package.

#:package Runax.Messaging.Transports.Azure.EventHubs@2.0.0

#:package directive can be used in C# file-based apps starting in .NET 10 preview 4. Copy this into a .cs file before any lines of code to reference the package.

#addin nuget:?package=Runax.Messaging.Transports.Azure.EventHubs&version=2.0.0
                    

                            Install as a Cake Addin

#tool nuget:?package=Runax.Messaging.Transports.Azure.EventHubs&version=2.0.0
                    

                            Install as a Cake Tool

The NuGet Team does not provide support for this client. Please contact its maintainers for support.

Runax.Messaging.Transports.Azure.EventHubs

Azure Event Hubs transport for Runax.Messaging. A runax topic maps to an event hub of the same name: publishing sends to that hub, and consuming runs an EventProcessorClient over a consumer group backed by a blob checkpoint store.

Install

dotnet add package Runax.Messaging
dotnet add package Runax.Messaging.Transports.Azure.EventHubs

Register

Attach the transport to a bus with its config object:

using Runax.Messaging;
using Runax.Messaging.Transports.Azure.EventHubs;

builder.Services.AddRunaxMessaging(messaging =>
{
    messaging.AddBus(bus =>
    {
        bus.AddTransport(new AzureEventHubsConfig
        {
            FullyQualifiedNamespace = "my-ns.servicebus.windows.net", // or ConnectionString
            ConsumerGroup = "orders-worker",
            BlobConnectionString = "<Azure Storage connection string>", // checkpoint store
            BlobContainerName = "runax-checkpoints",
        });
        bus.AddConsumer<OrderPlacedConsumer>();
    });
});

AzureEventHubsConfig lives in the Runax.Messaging.Transports.Azure.EventHubs namespace, so add that using. The config is validated at startup (DataAnnotations, when the AddBus block completes); bind it from an IConfiguration section instead of setting properties: bus.AddTransport<AzureEventHubsConfig>(builder.Configuration.GetSection("EventHubs")).

When you set FullyQualifiedNamespace (rather than a connection string), the transport authenticates with DefaultAzureCredential (managed identity, environment, Azure CLI, ...).

Provision the event hubs, consumer group, and blob container ahead of time.

Config

Set these directly on AzureEventHubsConfig.

Property	Default	Description
`FullyQualifiedNamespace`	`null`	Namespace host (e.g. `my-ns.servicebus.windows.net`); authenticates with `DefaultAzureCredential`. One of this or `ConnectionString` is required.
`ConnectionString`	`null`	Namespace connection string. Takes precedence over `FullyQualifiedNamespace` when both are set.
`ConsumerGroup`	`$Default`	Consumer group used when subscribing.
`BlobConnectionString`	`null`	Azure Storage connection string for the blob checkpoint store. Required to consume.
`BlobContainerName`	`null`	Blob container that holds ownership/checkpoint state. Required to consume.
`ProduceDeadLetterHub`	`false`	When `true`, a `DeadLetter` verdict republishes the event to a `{topic}.dead-letter` hub (which you must provision); when `false`, dead-lettered events are logged and dropped.
`RegisterHealthCheck`	`true`	Auto-register the `runax:{bus}` health check (inherited from `TransportConfig`).

Beyond the transport config, settings from the core package apply to the bus that runs this transport — AddConsumer<T>(), WithRetry(...), OnUnroutableMessage(...), ConfigureSerialization(...), and UseSerializer<T>() — all inside the same AddBus block. See Configuration & per-bus settings.

Behavior

Publish sends the serialized envelope to the event hub named after the runax topic (via EventHubProducerClient). PublishBatchAsync packs events into size-bounded EventDataBatches.
Subscribe runs an EventProcessorClient per topic over the configured consumer group, using a BlobCheckpointStore for ownership and checkpoints. Event Hubs has no per-message ack and no native dead-letter queue, so the dispatch verdict is mapped to checkpointing:
- Acknowledge → advance the checkpoint past the event.
- Requeue → do not checkpoint, so the partition is reprocessed from the last committed offset (by this run's next poll or another owner).
- DeadLetter → if ProduceDeadLetterHub is true, republish the event to a {topic}.dead-letter hub and checkpoint; otherwise log and checkpoint (drop). Either way the event is not reprocessed.

Health check

A check named runax:{bus} is registered automatically for each bus that runs this transport (RegisterHealthCheck = false on the config to opt out). The check pings the Event Hubs namespace to verify connectivity.

Telemetry

The transport reports messaging.system = "azure-event-hubs" on the spans and metrics emitted by the core package (activity source / meter "Runax.Messaging"); the messaging.runax.bus tag identifies the bus.

License

MIT

Product	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.

Compatible target framework(s)

Included target framework(s) (in package)

Learn more about Target Frameworks and .NET Standard.

net10.0
- Azure.Core (>= 1.62.0)
- Azure.Identity (>= 1.21.0)
- Azure.Messaging.EventHubs (>= 5.12.2)
- Azure.Messaging.EventHubs.Processor (>= 5.12.2)
- Azure.Storage.Blobs (>= 12.29.2)
- Microsoft.Extensions.Configuration (>= 10.0.11)
- Microsoft.Extensions.DependencyInjection.Abstractions (>= 10.0.11)
- Microsoft.Extensions.Diagnostics.HealthChecks (>= 10.0.10)
- Microsoft.Extensions.Hosting.Abstractions (>= 10.0.10)
- Microsoft.Extensions.Logging.Abstractions (>= 10.0.11)
- Microsoft.Extensions.Options (>= 10.0.10)
- Microsoft.Extensions.Options.ConfigurationExtensions (>= 10.0.10)
- Microsoft.Extensions.Options.DataAnnotations (>= 10.0.10)
- Runax.Messaging.Abstractions (>= 2.0.0)

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
2.0.0	103	9/10/2026
1.0.0	125	7/26/2026