ArkaSoftware.Extensions.MessageBus.Abstractions 2.0.0

ArkaSoftware.Extensions.MessageBus.Abstractions

ArkaSoftware.Extensions.MessageBus.Abstractions provides clean, extensible interfaces and models for building distributed applications using the Message Bus pattern in .NET. It includes contracts for sending and receiving commands and events, handling message inbox, and working with structured message envelopes.

✨ Features

• 📨 Send and receive events and commands
• 📦 Standardized message structure via Parcel
• 🔁 Idempotent message processing with IMessageInboxItemRepository
• 🔌 Clean separation of concerns with abstractions
• 🧪 Built-in Fake implementations for local testing and development

🧩 Core Interfaces

ISendMessageBus

Defines methods for publishing events and sending commands.

public interface ISendMessageBus
{
    void Publish<TInput>(TInput input);
    void SendCommandTo<TCommandData>(string destinationService, string commandName, TCommandData commandData);
    void SendCommandTo<TCommandData>(string destinationService, string commandName, string correlationId, TCommandData commandData);
    void Send(Parcel parcel);
}

IReceiveMessageBus

Defines how the service subscribes to events and receives commands.

public interface IReceiveMessageBus
{
    void Subscribe(string serviceId, string eventName);
    void Receive(string commandName);
}

IMessageConsumer

Defines how incoming commands and events are handled.

public interface IMessageConsumer
{
    Task<bool> ConsumeEvent(string sender, Parcel parcel);
    Task<bool> ConsumeCommand(string sender, Parcel parcel);
}

IMessageInboxItemRepository

Supports deduplication and idempotency by checking and storing received messages.

public interface IMessageInboxItemRepository
{
    bool AllowReceive(string messageId, string fromService);
    void Receive(string messageId, string fromService, string payload);
}

Parcel

Represents a structured message envelope, including headers and payload:

public class Parcel
{
    public string MessageId { get; set; }
    public string CorrelationId { get; set; }
    public string MessageName { get; set; }
    public Dictionary<string, object> Headers { get; set; }
    public string MessageBody { get; set; }
    public string Route { get; set; }
}

🧪 Fakes for Testing

FakeSendMessageBus

A fake implementation of ISendMessageBus that logs operations for test environments.

public class FakeSendMessageBus : ISendMessageBus
{
    public void Publish<TInput>(TInput input) { ... }
    public void SendCommandTo(...) { ... }
}

FakeReceiveMessageBus

Logs subscription and receive operations for testing.

public class FakeReceiveMessageBus : IReceiveMessageBus
{
    public void Receive(string commandName) { ... }
    public void Subscribe(string serviceId, string eventName) { ... }
}

FakeMessageConsumer

Simulates consuming commands and events, printing message info to the console.

public class FakeMessageConsumer : IMessageConsumer
{
    public Task<bool> ConsumeEvent(...) { ... }
    public Task<bool> ConsumeCommand(...) { ... }
}

✅ Use Cases

• Event-Driven Microservices

• Asynchronous Messaging

• Decoupling between services

• Outbox & Inbox patterns

• Integration with RabbitMQ, Kafka, Azure Service Bus, etc.

🏢 Maintained by

ArkaSoftware
📧 Email Us
🌐 Web Site Visit