Program.cs

using NATS.Client.Core;

using Sample.Nats.WebApi;

using SecretStore;

using SlimMessageBus;
using SlimMessageBus.Host;
using SlimMessageBus.Host.Nats;
using SlimMessageBus.Host.Nats.Config;
using SlimMessageBus.Host.Serialization.SystemTextJson;

var builder = WebApplication.CreateBuilder(args);

builder.Services.AddEndpointsApiExplorer();
builder.Services.AddSwaggerGen();

Secrets.Load(@"..\..\..\..\..\secrets.txt");

var endpoint = Secrets.Service.PopulateSecrets(builder.Configuration["Nats:Endpoint"]);
var topic = Secrets.Service.PopulateSecrets(builder.Configuration["Nats:Topic"]);

// doc:fragment:ExampleConfiguringMessageBus
builder.Services.AddSlimMessageBus(mbb =>
{
    mbb.WithProviderNats(cfg =>
    {
        cfg.Endpoint = endpoint;
        cfg.ClientName = $"MyService_{Environment.MachineName}";
        cfg.AuthOpts = NatsAuthOpts.Default;
    });

    // pub/sub
    mbb
        .Produce<PingMessage>(x => x.DefaultTopic(topic))
        .Consume<PingMessage>(x => x.Topic(topic).Instances(1));

    // queue
    mbb
        .Produce<QueueMessage>(x => x.DefaultQueue(topic))
        .Consume<QueueMessage>(x => x.Queue(topic).Instances(1));

    mbb.AddServicesFromAssemblyContaining<PingConsumer>();
    mbb.AddServicesFromAssemblyContaining<QueueMessage>();
    mbb.AddJsonSerializer();
});
// doc:fragment:ExampleConfiguringMessageBus

var app = builder.Build();

if (app.Environment.IsDevelopment())
{
    app.UseSwagger();
    app.UseSwaggerUI();
}

app.UseHttpsRedirection();

app.MapGet("/publish-message", (IMessageBus bus, CancellationToken cancellationToken) =>
{
    PingMessage pingMessage = new(0, Guid.NewGuid());
    bus.Publish(pingMessage, cancellationToken: cancellationToken);
});

app.MapGet("/publish-message-queue", (IMessageBus bus, CancellationToken cancellationToken) =>
{
    QueueMessage queueMessage = new(0, Guid.NewGuid());
    bus.Publish(queueMessage, cancellationToken: cancellationToken);
});

app.Run();