PulseBus 1.0.4

🚌 PulseBus

Fast. Minimal. Universal.

PulseBus is a lightweight, provider-agnostic messaging abstraction for .NET, designed to unify message publishing and consuming across multiple providers with a focus on Clean Architecture and High Performance.

📑 Table of Contents

• Features
• Installation
• Quick Start
• Usage
  • Publishing
  • Subscribing
• Architecture
• Supported Providers
• Support
• License

🚀 Features

• Unified API: Single interface to interact with RabbitMQ, SQS, Kafka, etc.
• Middleware Pipeline: Extensible pipeline similar to ASP.NET Core.
• Flexible Serialization: Support for JSON, Protobuf, MessagePack, and custom serializers.
• Resilience: Built-in retry policies and idempotency support.
• Lightweight: Zero external dependencies in the core (PulseBus package).
• Extensible: Easily add new providers through a plugin-based design.

📦 Installation

Install the base package via NuGet:

dotnet add package PulseBus

Then, add the provider you need:

🧩 Quick Start

Register PulseBus in your dependency injection container (Program.cs or Startup.cs):

using PulseBus.Extensions;

services.AddPulseBus(builder =>
{
    // Configure your provider
    builder.UseRabbitMq(options =>
    {
        options.Host = "localhost";
        options.Username = "guest";
        options.Password = "guest";
    });

    // Select your preferred serializer
    builder.UseJsonSerializer();
});

💻 Usage

Publishing

Send messages asynchronously to any configured bus:

await bus.PublishAsync("user.requested", new UserRequested
{
    Email = "andres@example.com",
    Name = "Andrés"
});

Subscribing

Define message handlers easily:

bus.Subscribe<UserRequested>("user.requested", async (msg, ctx) =>
{
    Console.WriteLine($"Processing: {msg.Email}");
    
    // Acknowledge the message
    await ctx.AcknowledgeAsync();
});

🧱 Architecture

PulseBus is built on solid interfaces that allow you to decouple your business logic from the messaging infrastructure:

• IMessageBus: Main entry point.
• IMessageProducer / IMessageConsumer: Transport abstractions.
• IMessageMiddleware: For logging, validation, or telemetry.
• IIdempotencyStore: Integrated duplicate control.

💖 Support

This project is developed and maintained by Andrés Mariño. If you find this library useful, consider supporting its continued development:

• Bitcoin (BTC): bc1p9zqgxghkjhauruhsza9n382e6kp5tpj4xtzu2csv4mypsdtdc4tqvdyg86
• Ko-fi:

📝 License

This project is licensed under the MIT License. See the LICENSE file for details.

Made with ❤️ for the .NET community