👁 Image
Sora.Messaging.Core 0.4.0

Sylin.Sora.Messaging.Core

Core messaging abstractions and helpers for Sora: bus configuration, auto-registration, and options binding.

• Target framework: net9.0
• License: Apache-2.0

Install

dotnet add package Sylin.Sora.Messaging.Core

Links

• Messaging reference: https://github.com/sylin-labs/sora-framework/tree/dev/docs/reference

Usage

Declare messages with attributes, then send via extension methods.

using Sora.Messaging;

[Message(Alias = "User.Registered", Version = 1)]
public sealed record UserRegistered(
	string UserId,
	[Header("x-tenant")] string Tenant,
	[IdempotencyKey] string EventId,
	[PartitionKey] string Partition,
	[DelaySeconds] int DelaySeconds = 0);

// Single send (DefaultBus)
await new UserRegistered("u-123", "acme", "evt-1", "acme:u-123").Send();

// Send to a specific bus
await new UserRegistered("u-456", "acme", "evt-2", "acme:u-456").SendTo("rabbit");

// Batch send
var batch = new object[]
{
	new UserRegistered("u-789", "acme", "evt-3", "acme:u-789"),
	new UserRegistered("u-790", "acme", "evt-4", "acme:u-790")
};
await batch.Send(); // default bus
await batch.SendTo("rabbit"); // specific bus

Register handlers tersely

// Most concise (no envelope):
builder.Services.On<UserRegistered>(msg => Console.WriteLine($"New user: {msg.UserId}"));

// Async with CancellationToken
builder.Services.On<UserRegistered>((msg, ct) => HandleAsync(msg, ct));

// Keep envelope when needed
builder.Services.OnMessage<UserRegistered>((env, msg, ct) => HandleWithEnvelope(env, msg, ct));

// Intent-signaling aliases
builder.Services.OnEvent<UserRegistered>(msg => IndexUser(msg.UserId));
builder.Services.OnCommand<ReindexAll>(ct => ReindexAsync(ct));

Notes

• Send/SendTo are defined on MessagingExtensions and operate per-message when batching.
• Headers/correlation/idempotency are promoted from attributes; partitions add a .p{n} suffix to routing keys.