Generic Web Apis for Service Bus - Extension Package

Service Bus Consumer with IOSP and Command Pattern

This CleanCodeJN package for Service Bus simplifies the development of asynchronous microservices by providing a framework that leverages the power of MediatR and IOSP to consume service bus events from topics and execute commands to process these events.

Features

• Built in Service Bus Consumer for multiple configurable Topics and Subscriptions
• Uses Mediator and IOSP to execute Commands for processing Events
• Built in Retry concept
• Custom Configuration implementation required for event logging and configuration management
• On latest .NET 8.0

How to use

• Implement IServiceBusConsumerConfigurationService
• Add RegisterServiceBusConsumer() to your Program.cs
• Add Service Bus Configuration to your appsettings.json and your Configuration classes
• Consume Events by just posting events to the Service Bus

Step by step explanation

Implement the full IServiceBusConsumerConfigurationService

public class SampleServiceBusConsumerConfigurationService( IOptionsMonitor<SampleConfiguration> configuration, ILogger<SampleServiceBusConsumerConfigurationService> logger) : IServiceBusConsumerConfigurationService { public virtual bool IsLocalEnvironment() => Environment.GetEnvironmentVariable("IS_LOCAL")?.Equals("true") ?? false; public virtual void PrintLogoForDebugging() => StringExtensions.PrintLogo(); public virtual string PrintStartTextForDebugging() => "Please add the event as JSON and press ENTER twice."; public virtual string GetServiceBusConnectionString() => configuration.CurrentValue.ServiceBus.ConnectionString; public virtual ServiceBusConfiguration GetServiceBusTopicConfiguration() => configuration.CurrentValue.ServiceBus; public virtual void LogIncomingEvent(string name, string body) => logger.LogDebug($"EventRequest_{name.Replace(" ", string.Empty)}", body); public virtual string MaxRetryMessage(ProcessMessageEventArgs args) => "Max Retry reached"; public virtual void LogMaxRetryReached(ProcessMessageEventArgs args) => logger.LogCritical(message: MaxRetryMessage(args)); public virtual List<Assembly> GetCommandAssemblies() => [typeof(UpdateInvoiceEventRequest).Assembly]; public virtual Task LogAndHandleException(Exception exception, string message) { logger.LogCritical(exception, message); return Task.CompletedTask; } public virtual void LogExecutionResponse(string body, Response response, Exception exception = null) => logger.LogDebug($"EventResponse_{JsonSerializer.Deserialize<JsonElement>(body).GetProperty("Name").GetString().Replace(" ", string.Empty)}_{(response.Succeeded ? "Success" : "Failure")}", new Dictionary<string, string> { { nameof(response.Succeeded), response.Succeeded.ToString() }, { nameof(response.Message), response.Message ?? exception?.Message }, { nameof(response.Info), response.Info }, { nameof(exception), exception?.StackTrace }, { "data", body } }); }