Fly.Shared.Messaging 1.2.1

Fly.Shared.Messaging

MassTransit/RabbitMQ wiring and platform event contracts for FlyOS business app integration.

Installation

<PackageReference Include="Fly.Shared.Messaging" Version="1.*" />

Note: Fly.Shared.Messaging depends on Fly.Shared.Core and will pull it in automatically.

What's Included

Extension Method

Platform Event Contracts

All events are C# record types in Fly.Shared.Messaging.Events.

Tenant Events

User Events

License Events

Settings Events

Service Events

Notification Commands

Quick Start

Register in Program.cs

var builder = WebApplication.CreateBuilder(args);

builder.Services.AddFlyCore();
builder.Services.AddFlyMessaging(builder.Configuration, x =>
{
    x.AddConsumersFromNamespaceContaining<TenantCreatedConsumer>();
    // Optional: EF Core outbox for exactly-once delivery
    x.AddEntityFrameworkOutbox<MyAppDbContext>(o => o.UseBusOutbox());
});

Implement a Consumer

using Fly.Shared.Messaging.Events;
using MassTransit;

public class TenantCreatedConsumer : IConsumer<TenantCreated>
{
    private readonly MyAppDbContext _db;

    public TenantCreatedConsumer(MyAppDbContext db) => _db = db;

    public async Task Consume(ConsumeContext<TenantCreated> context)
    {
        var tenantId = context.Message.TenantId;

        _db.MyEntities.Add(new MyEntity
        {
            TenantId = tenantId,
            Name = "Default",
            IsActive = true
        });

        await _db.SaveChangesAsync();

        // Signal back to the platform that this service is ready for this tenant
        await context.Publish(new ServiceInitialized(tenantId, "my-app"));
    }
}

Publish a Notification

using Fly.Shared.Messaging.Events;
using MassTransit;

public class ProjectService
{
    private readonly IPublishEndpoint _bus;

    public async Task NotifyAssigneeAsync(Guid tenantId, Guid userId, string projectName)
    {
        await _bus.Publish(new SendNotification(
            TenantId: tenantId,
            Channel: "in-app",
            RecipientUserIds: [userId],
            TemplateId: "project-assigned",
            TemplateData: new() { ["projectName"] = projectName }
        ));
    }
}

Configuration

Add to appsettings.json:

{
  "RabbitMQ": {
    "Host": "localhost",
    "VirtualHost": "/",
    "Username": "guest",
    "Password": "guest"
  }
}

Retry Policy

AddFlyMessaging configures exponential backoff automatically:

• 5 retry attempts
• Min interval: 1 second
• Max interval: 5 minutes
• Delta: 5 seconds per step

Dependencies

• Fly.Shared.Core 1.x
• MassTransit.RabbitMQ 8.x

Related Packages

• Fly.Shared.Core — Multi-tenancy, auth, caching, API models. Required by this package.