Pervaxis.Core.Messaging 1.6.0

Pervaxis.Core.Messaging

AWS SQS message publishing with typed domain event support and transport envelope metadata. Implements Section 13 of the Pervaxis Platform Spec.

AWS SQS only. RabbitMQ and other message brokers are not supported by design — all environments (dev, UAT, staging, production) use AWS SQS.

Installation

dotnet add package Pervaxis.Core.Messaging

Registration

builder.Services.AddPervaxisMessaging(options =>
{
    options.ServiceName = "order-service";
    options.Sqs.Region = "ap-south-1";
    options.Sqs.DefaultQueueUrl = "https://sqs.ap-south-1.amazonaws.com/123456789/orders";
});

Or via appsettings.json:

{
  "Pervaxis": {
    "Messaging": {
      "ServiceName": "order-service",
      "Sqs": {
        "Region": "ap-south-1",
        "DefaultQueueUrl": "https://sqs.ap-south-1.amazonaws.com/123456789/orders",
        "QueueUrlMappings": {
          "OrderPlaced": "https://sqs.ap-south-1.amazonaws.com/123456789/order-events",
          "PaymentProcessed": "https://sqs.ap-south-1.amazonaws.com/123456789/payment-events"
        },
        "EventBridgeBusArn": "arn:aws:events:ap-south-1:123456789:event-bus/pervaxis-platform"
      }
    }
  }
}

Publishing Domain Events

public class OrderService(IMessagePublisher publisher)
{
    public async Task PlaceOrderAsync(PlaceOrderCommand command, CancellationToken ct)
    {
        // ... domain logic ...

        await publisher.PublishAsync(new OrderPlacedEvent
        {
            EventId = Guid.NewGuid(),
            TenantId = command.TenantId,
            CorrelationId = command.CorrelationId,
            OccurredAt = DateTime.UtcNow,
            OrderId = order.Id
        }, ct);
    }
}

Batch Publishing

await publisher.PublishBatchAsync(domainEvents, cancellationToken);
// Internally batches into 10-message SQS chunks per AWS SDK limit.

Message Envelope

Every message is wrapped automatically:

{
  "envelopeId": "3fa85f64-5717-4562-b3fc-2c963f66afa6",
  "messageType": "Acme.Orders.Events.OrderPlacedEvent",
  "messageVersion": 1,
  "sourceService": "order-service",
  "tenantId": "tenant-abc",
  "correlationId": "req-corr-xyz",
  "enqueuedAt": "2026-04-16T10:30:00Z",
  "payload": "{ ... json serialized event ... }"
}

AWS IAM Requirements

The service role requires the following SQS permissions:

{
  "Effect": "Allow",
  "Action": ["sqs:SendMessage", "sqs:SendMessageBatch"],
  "Resource": "arn:aws:sqs:ap-south-1:123456789:*"
}

Pervaxis Platform · Clarivex Technologies · https://clarivex.tech