Atya.Messaging.InMemory 1.0.0

Atya.Messaging.InMemory

In-memory messaging transport for tests, local development, and contract validation in Atya services.

Overview

Atya.Messaging.InMemory is a small in-process transport that implements the Atya.Messaging.Abstractions publisher and consumer registry contracts. It is intended for tests, local development, samples, and contract validation before a durable or broker-backed transport is introduced.

The bus stores accepted envelopes in memory and delivers them to subscribed consumers in registration order.

Features

• InMemoryMessageBus<TMessage> implements publishing and consumer registration.
• DelegateMessageConsumer<TMessage> adapts a delegate to the consumer contract.
• Published envelopes are retained for assertions.
• Subscriptions can be removed through IMessageSubscription.
• No broker, hosting, serializer, or dependency injection dependency.

Installation

dotnet add package Atya.Messaging.InMemory

Install-Package Atya.Messaging.InMemory

<PackageReference Include="Atya.Messaging.InMemory" Version="<latest-stable>" />

Quick Start

using Atya.Messaging.Abstractions;
using Atya.Messaging.InMemory;

var bus = new InMemoryMessageBus<string>();

await bus.SubscribeAsync(
    new DelegateMessageConsumer<string>((envelope, _) =>
    {
        Console.WriteLine(envelope.Message);
        return ValueTask.CompletedTask;
    }));

await bus.PublishAsync(
    "customer.created",
    new MessagePublishOptions(messageId: "message-1", correlationId: "correlation-1"));

Feature Tour

Assert published messages in a test:

using Atya.Messaging.InMemory;

var bus = new InMemoryMessageBus<string>();

await bus.PublishAsync("customer.created");

Console.WriteLine(bus.PublishedMessages[0].Message);

Remove a consumer:

using Atya.Messaging.InMemory;

var bus = new InMemoryMessageBus<string>();
var subscription = await bus.SubscribeAsync(
    new DelegateMessageConsumer<string>((_, _) => ValueTask.CompletedTask));

await subscription.UnsubscribeAsync();

Error Codes

This package does not define Result error codes. Invalid programmer input is rejected with standard .NET argument exceptions through Atya.Foundation.Guards.

Why These Dependencies

• Atya.Messaging.Abstractions provides the publisher, consumer, subscription, and envelope contracts.
• Atya.Foundation.Guards provides consistent argument validation for public entry points.

Links

• Repository: https://github.com/AtyaLibraries/Messaging.InMemory
• NuGet: https://www.nuget.org/packages/Atya.Messaging.InMemory
• Samples: https://github.com/AtyaLibraries/Messaging.InMemory/tree/development/samples
• License: https://github.com/AtyaLibraries/Messaging.InMemory/blob/development/LICENSE