SquidStd.Messaging
0.7.0
dotnet add package SquidStd.Messaging --version 0.7.0
NuGet\Install-Package SquidStd.Messaging -Version 0.7.0
<PackageReference Include="SquidStd.Messaging" Version="0.7.0" />
<PackageVersion Include="SquidStd.Messaging" Version="0.7.0" />
<PackageReference Include="SquidStd.Messaging" />
paket add SquidStd.Messaging --version 0.7.0
#r "nuget: SquidStd.Messaging, 0.7.0"
#:package SquidStd.Messaging@0.7.0
#addin nuget:?package=SquidStd.Messaging&version=0.7.0
#tool nuget:?package=SquidStd.Messaging&version=0.7.0
<p align="center"> <img src="https://raw.githubusercontent.com/tgiachi/squid-std/main/assets/icon.png" alt="SquidStd" width="120" height="120" /> </p>
<h1 align="center">SquidStd.Messaging</h1>
<p align="center"> <a href="https://www.nuget.org/packages/SquidStd.Messaging/"><img src="https://img.shields.io/nuget/v/SquidStd.Messaging.svg" alt="NuGet" /></a> <img src="https://img.shields.io/nuget/dt/SquidStd.Messaging.svg" alt="Downloads" /> <a href="https://tgiachi.github.io/squid-std/articles/messaging.html"><img src="https://img.shields.io/badge/docs-DocFX-1390A3.svg" alt="docs" /></a> <img src="https://img.shields.io/badge/license-MIT-blue.svg" alt="license" /> </p>
In-memory transport for SquidStd.Messaging. Provides a channel-backed IQueueProvider with per-queue
buffering, round-robin delivery to subscribers, retry/dead-letter handling, and metrics — registered
with a single AddInMemoryMessaging() call. Ideal for single-process apps, tests, and local dev.
Install
dotnet add package SquidStd.Messaging
Features
- One-line registration:
container.AddInMemoryMessaging()(facade, provider, serializer, metrics). - Channel-based per-queue buffering with a dedicated consumer loop.
- Round-robin delivery across multiple subscribers of the same queue.
- Retry with configurable max attempts and dead-letter queues (
MessagingOptions). - Built-in delivery metrics via
MessagingMetricsProvider.
Usage
using DryIoc;
using SquidStd.Messaging.Abstractions.Interfaces;
using SquidStd.Messaging.Extensions;
var container = new Container();
container.AddInMemoryMessaging();
var queue = container.Resolve<IMessageQueue>();
await queue.PublishAsync("orders", new { Id = 1 });
Key types
| Type | Purpose |
|---|---|
MessagingRegistrationExtensions |
AddInMemoryMessaging(...) registration. |
InMemoryQueueProvider |
Channel-based in-memory IQueueProvider. |
License
MIT — part of SquidStd.
| 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
- DryIoc.dll (>= 5.4.3)
- SquidStd.Core (>= 0.7.0)
- SquidStd.Messaging.Abstractions (>= 0.7.0)
NuGet packages
This package is not used by any NuGet packages.
GitHub repositories
This package is not used by any popular GitHub repositories.