Consumers.cs

namespace Sample.Nats.WebApi;

using SlimMessageBus;

public class PingConsumer(ILogger<PingConsumer> logger) : IConsumer<PingMessage>, IConsumerWithContext
{
    public IConsumerContext? Context { get; set; }

    public Task OnHandle(PingMessage message, CancellationToken cancellationToken)
    {
        logger.LogInformation("Got message {Counter} on topic {Path}", message.Counter, Context?.Path);
        return Task.CompletedTask;
    }
}

public class QueueConsumer(ILogger<QueueConsumer> logger) : IConsumer<QueueMessage>, IConsumerWithContext
{
    public IConsumerContext? Context { get; set; }

    public Task OnHandle(QueueMessage message, CancellationToken cancellationToken)
    {
        logger.LogInformation("Got message {Counter} on queue {Path}", message.Counter, Context?.Path);
        return Task.CompletedTask;
    }
}