using System;

public class Program

{

    public static void Main()

    {

        await new MicroserviceService<ServiceContainer>()

            .UseMessageBus<ServiceBusConfiguration>((c, settings) => c.WithRabbitMQCluster(settings.LoanManagementRabbitMQCluster))

            .UsePostgreSql()

            .UseFeatureToggling()

            .UseWebApi<WebApiStartup>()

            .Run();

    }

}

​

public class ServiceBusConfiguration

{

    public void InitMessagebus(IMessageBusFactory factory)

    {

        factory.Subscribe<LoanCretedEvent>();

    }

}

​

public class ServiceContainer

{

    public void InitContainer(ServiceContainer container)

    {

        // explicit DI wiring, no auto-magic. Helps with discoverability

        // and troublshooting. 

        container.Singleton<ILoanService, LoanService>();

        // HTTP and GRPC clients, etc

        container.GrpcClient<ICustomerGrpcClient, CustomerGrpClient>();

        // Message bus handlers

        // Again, can be auto-wired, via Scrutor similar

        container.Singleton<IMessageHandler<LoanCreatedEvent>>, LoanCreatedHandler>();

    }

}

​

public class LoanCreatedHandler : IMessgeHandler<LoanCreatedEvent>

{

    private IRepository<Loans> loanRepository;

    public LoanCreatedHandler(IRepository<Loans> loanRepository,

    IPublisher<SendEmailCommand> emailCommandPublisher)

    {

      this.loanRepository = loanRepository;

    }

​

    [Transaction]

    public void Handle<LoanCratedEvent>(LoanCreatedEvent loanCreated){

       emailCommandPublisher.Publish(new SendEmailCommand(){

          Template = "congratulations_with_your_new_purchase.tmpl",

          // extra data for renderind email

       });

    }

}

​

public class LoanCreatedEvent : IEvent

{

   public string Id { get; set; }  

   public string ProductId { get; set; }  

   public LoanStatus Status { get; set; }  

   // etc

}