TCIS.EventBus 1.0.0-rc.14

TCIS.EventBus

The TCIS.EventBus library provides an Event Bus wrapper (based on DotNetCore.CAP) to standardize distributed event handling, message queuing, and the outbox pattern within the TCIS multi-tier application ecosystem (Microservices).

🌟 Features

• Publish/Subscribe: Easily send and receive events through distributed protocols.
• Outbox Pattern: Ensures data consistency when integrated with Entity Framework Core.
• Seamless Integration: Supports built-in Dependency Injection (DI) and automatic lifecycle management.
• High Extensibility: Supports multiple transport layers (Kafka, RabbitMQ, In-Memory) and storage layers (SQL Server, PostgreSQL, In-Memory).

📦 Installation

dotnet add package TCIS.EventBus

(Note: You also need to install the appropriate providers, such as TCIS.EventBus.Kafka and TCIS.EventBus.SqlServer)

🚀 Setup & Usage

1. Registration in Program.cs

Register TCIS.EventBus into the Service Collection using the AddTEventBus method:

builder.Services.AddTEventBus(options =>
{
    // Register Storage (Example: InMemory)
    options.UseInMemoryStorage();

    // Register Transport (Example: Kafka)
    options.UseKafka("localhost:9092");

    // Configure advanced options
    options.FailedRetryCount = 5;
});

2. Sending Events (Publisher)

Use IEventPublisher (which is automatically registered in DI):

public class OrderService
{
    private readonly IEventPublisher _eventPublisher;

    public OrderService(IEventPublisher eventPublisher)
    {
        _eventPublisher = eventPublisher;
    }

    public async Task CreateOrderAsync(Order order)
    {
        // ... processing logic

        // Publish event
        await _eventPublisher.PublishAsync("order.created", new { OrderId = order.Id, Amount = order.Amount });
    }
}

3. Receiving Events (Subscriber)

Create a Subscriber class (must be registered as Transient or Singleton) and apply the [EventSubscribe] attribute:

public class OrderSubscriber : IEventSubscribe
{
    [EventSubscribe("order.created")]
    public async Task OnOrderCreated(OrderCreatedEvent eventData)
    {
        Console.WriteLine($"Received order creation event: {eventData.OrderId}");
        await Task.CompletedTask;
    }
}

⚙️ Configuration Options

The primary configuration settings can be adjusted within the EventBusOptions parameter: