Table of Contents

SquidStd.Messaging.Abstractions

Transport-agnostic messaging contracts for SquidStd. It defines the typed queue facade (IMessageQueue), the low-level provider/serializer/metrics contracts, the message-listener interfaces, and the shared MessageQueue facade plus default serializer and metrics. Pick a transport implementation (in-memory or RabbitMQ) from a companion package.

Install

dotnet add package SquidStd.Messaging.Abstractions

Usage

using SquidStd.Messaging.Abstractions.Interfaces;

public sealed class OrderCreated { public int Id { get; init; } }

public sealed class OrderListener : IQueueMessageListener<OrderCreated>
{
    public void Handle(OrderCreated message) { /* ... */ }
}

// Resolve IMessageQueue from a transport package (in-memory or RabbitMQ).
public async Task PublishAsync(IMessageQueue queue)
    => await queue.PublishAsync("orders", new OrderCreated { Id = 1 });

Key types

Type Purpose
IMessageQueue Typed publish/subscribe facade.
IQueueProvider Transport contract (per backend).
IMessageSerializer Payload (de)serialization.
IQueueMessageListener<T> Subscriber callbacks.
IMessagingMetrics Delivery metrics sink.
MessagingOptions Delivery attempts, retry delay, and dead-letter-queue suffix.

License

MIT - part of SquidStd.

Edit this page