Korjn.Amqp.Client 9.0.3

Korjn.Amqp.Client

appsettings.json

{
  "AmqpClient":{
    "Artemis": {
      "Host": "xxx.xxx.xxx.xxx",    
      "Port": "5672",
      "CredentialFile":"login.json"
    },
    "MqQPid": {
      "Host": "xxx.xxx.xxx.xxx",    
      "Port": "5675",
      "CredentialFile":"login.json"
    }
  }
}

// or default

{
  "AmqpClient":{
      "Host": "xxx.xxx.xxx.xxx",    
      "Port": "5672",
      "CredentialFile":"login.json"
    }  
}

Service registration

using Korjn.Amqp.DependencyInjection;
...

var builder = Host.CreateApplicationBuilder(args);

// default
builder.Services.AddAmqpClient(options =>
{
     builder.Configuration.GetRequiredSection("AmqpClient").Bind("Artemis", options);
});

// keyed services
/*builder.Services.AddAmqpClient("Artemis", options =>
{
    builder.Configuration.GetRequiredSection("AmqpClient").Bind("Artemis", options);
});*/

...

Injection

using Korjn.Amqp;
namespace DependencyInjection.Example;

public class Worker(ILogger<Worker> logger,
                    /*default*/ IAmqpClient amqpClient,
                    //[FromKeyedServices("Artemis")] IAmqpClient amqpClient,                    
                    IConfiguration configuration) : BackgroundService
{
    private readonly ILogger<Worker> _logger = logger;
    private readonly IAmqpClient amqpClient = amqpClient;
    private readonly IConfiguration configuration = configuration;

    private async ValueTask<bool> HandleMessage(AmqpMessage message)
    {        
        //_logger.LogTrace("{message}", message);

        await Task.Delay(500);

        return true;
    }

    /*private async ValueTask<bool> HandleMessage(Message message)
    {
        await Task.Delay(500);

        return true;
    }*/

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        await Task.Delay(TimeSpan.FromSeconds(1), stoppingToken);

        _logger.LogInformation("Worker running at: {time}", DateTimeOffset.Now);

        var reciever = amqpClient.CreateReceiver("test-receiver", "test::qtasks");
        var channel = reciever.CreateChannel(50, _logger);

        var taskCount = int.Parse(configuration["ThreadCount"] ?? "20");

        var tasks = Enumerable.Range(0, taskCount).Select(i => channel.ConsumeAsync(HandleMessage, stoppingToken)).ToArray();

        await reciever.ReceiveAsync(channel.Writer, stoppingToken);

        Task.WaitAll(tasks, stoppingToken);        
    }
}