NPipeline.Connectors.Azure.ServiceBus 0.70.1

NPipeline Azure Service Bus Connector

Source and sink nodes for Azure Service Bus in NPipeline pipelines, on NPipeline's shared messaging layer.

About NPipeline

NPipeline is a high-performance, extensible data processing framework for .NET that enables developers to build scalable and efficient pipeline-based applications. It provides a rich set of components for data transformation, aggregation, branching, and parallel processing, with built-in support for resilience patterns and error handling.

Installation

dotnet add package NPipeline.Connectors.Azure.ServiceBus

Targets .NET 8.0, 9.0 and 10.0.

Features

• Receiver-based sources: messages are received while fewer than MaxInFlight are unsettled, and their locks are renewed while they wait, so sinks can batch freely.
• Queues, subscriptions and sessions (several sessions at once, each in order).
• Batched sends that keep a received message's id, session, correlation id and properties across a hop.
• Complete, abandon, dead-letter with a reason, or defer each message.
• One messaging model: messages are acknowledged or rejected once, and sink.Acknowledging() makes any sink (SQL, HTTP, another broker) acknowledge each message once it is written.
• Shared JSON defaults with the JSON connector (camelCase, case-insensitive, enums as names, [Column]), or a source-generated JsonSerializerContext for Native AOT.
• Undeserializable messages go through the shared row-error handler: fail the read, skip, or send the whole message to the pipeline's dead-letter sink.
• Failed writes fail, requeue the source message, or go to the dead-letter sink.

Usage

using Azure.Identity;
using Azure.Messaging.ServiceBus;
using NPipeline.Connectors.Azure.ServiceBus;
using NPipeline.Connectors.Messaging;

await using var client = new ServiceBusClient("mynamespace.servicebus.windows.net", new DefaultAzureCredential());
var orders = ServiceBusConnector.Source<Order>(client, "orders");
var invoices = ServiceBusConnector.Sink<Invoice>(client, "invoices");

builder.AddSink(invoices.Acknowledging(), "invoices");

See the Azure Service Bus connector documentation and Message Queues: Shared Behaviour for every option.

Related Packages

• NPipeline - Core pipeline framework
• NPipeline.Connectors - Shared messaging layer, storage abstractions and base connectors
• NPipeline.Extensions.DependencyInjection - Dependency injection integration

License

This package is licensed under the Business Source License 1.1.

Free for non-production use. Production use is free for organizations with 4 or fewer developers and annual revenue of $5M AUD or less. Larger organizations require a commercial license. This license automatically converts to MIT two years after each release.