HyperDev.ActiveMQ 1.2.1

HyperDev.ActiveMQ

Typed JSON messaging for ActiveMQ Artemis, built on ArtemisNetClient, part of the HyperDev Fatum framework.

• Named broker endpoints from the ActiveMQ configuration section (IEndpointManager, registered with AddEndpointFactory, with an EndpointResolving event for custom resolution)
• AddActiveMq(configuration, name, aliases): registers an ArtemisNetClient connection on the configured endpoints
• Typed consumers (ITypedConsumer<TMessage>, AddTypedConsumer): JSON body deserialized, consumer resolved in a DI scope, message accepted on success and rejected (and logged) on exception
• Typed producers (ITypedProducer<TMessage>, MessageProducer<TMessage>): messages serialized to JSON with Newtonsoft.Json

Installation

dotnet add package HyperDev.ActiveMQ

Quick start

{
  "ActiveMQ": {
    "Endpoints": [
      { "Name": "Primary", "Server": "localhost", "Port": 5672, "User": "artemis", "Password": "artemis", "Scheme": "Amqp" }
    ]
  }
}

using ActiveMQ.Artemis.Client;
using ActiveMQ.Artemis.Client.Extensions.DependencyInjection;
using ActiveMQ.Artemis.Client.Extensions.Hosting;
using HyperDev.ActiveMQ;
using HyperDev.DependencyInjection;

var builder = WebApplication.CreateBuilder(args);

builder.Services.AddScoped<OrderCreatedConsumer>();

var activeMq = builder.Services.AddActiveMq(builder.Configuration, "orders-bus", "Primary");

activeMq.AddTypedConsumer<OrderCreated, OrderCreatedConsumer>("orders", RoutingType.Anycast, new ConsumerOptions());

builder.Services.AddActiveMqHostedService();

builder.Build().Run();

public record OrderCreated(int OrderId, decimal Total);

public class OrderCreatedConsumer : ITypedConsumer<OrderCreated>
{
    public Task ConsumeAsync(OrderCreated message, ConsumerContext context)
    {
        Console.WriteLine($"Order {message.OrderId} created, total {message.Total}");

        return Task.CompletedTask;
    }
}

Requirements

An Apache ActiveMQ Artemis broker reachable over AMQP (Scheme: Amqp, Amqps, Ws or Wss).

Target frameworks

.NET 8.0, .NET 10.0

License

MIT, © Ivan Senatore, Wemake Informatica srl. Third-party dependencies keep their own licenses (ArtemisNetClient and its extensions: MIT, Newtonsoft.Json: MIT, Microsoft.Extensions.*: MIT).