SmartTender.MessageBroker.AspNetCore 2.0.14

Smarttender.MessageBroker.AspNetCore NuGet Package

Installation

To use this package, you can install it via NuGet Package Manager or directly add it to your project's dependencies in the .csproj file.

dotnet add package Smarttender.MessageBroker.AspNetCore

Usage

Dependency Injection method

public static class SmartMessageBrokerServicesDi { 
// Adding required services to the service collection public static IServiceCollection
public static IServiceCollection AddSmartMessageBroker(this IServiceCollection services, Action<BrokerConfigBase> configureApp)

// Starting consuming queues
public static IApplicationBuilder UseSmartMessageBrokerConsumers(this IApplicationBuilder app);

DI Registration Examples

using SmartMessageBroker;
using Smarttender.MessageBroker.Producer.Consumers;

var builder = WebApplication.CreateBuilder(args);

// Add services to the container.
builder.Services.AddControllers();

builder.Services.AddSmartMessageBroker(
	cfg =>
	{
		cfg.ProducerConnectionString = builder.Configuration["RABBIT_CONNECTION_WRITE"]; // write connection string
		cfg.ConsumerConnectionString = builder.Configuration["RABBIT_CONNECTION_READ"]; // read connection string
		cfg.AddConsumer<CommercialStringMessageConsumer, StringDataMessage>(); // add consumer
		cfg.AddConsumer<CommonStringMessageConsumer, StringDataMessage>();
		cfg.AddConsumer<ProzorroSaleStringMessageConsumer, StringDataMessage>();
		cfg.AddConsumer<ProzorroPurchaseStringMessageConsumer, StringDataMessage>();
		cfg.LogTo(Console.WriteLine); // log debug messages to console
		cfg.LogExceptionsTo((ex, m) => {
			Console.WriteLine($"Exception: {ex.Message}, {m}"); // log exceptions to console
		});
		cfg.AddMessageProcessingLogger<MessageLogger>(); // add message processing logger
	});

var app = builder.Build();

// Configure the HTTP request pipeline.

app.UseHttpsRedirection();
app.UseSmartMessageBrokerConsumers();

app.MapControllers();

app.Run();

Replace builder.Configuration["RABBIT_CONNECTION_WRITE"] and builder.Configuration["RABBIT_CONNECTION_READ"] with your actual RabbitMQ connection strings.

Config method usage

There is a BrokerConfigBase class that is used to configure the message broker. It has the following properties and methods:

	public abstract class BrokerConfigBase
	{
		public TimeSpan? SendTimeout { get; set; } // Timeout for sending messages
		public TimeSpan? RecieveTimeout { get; set; } // Timeout for recieving messages
		public string ProducerConnectionString { get; set; } // Connection string for producer
		public string ConsumerConnectionString { get; set; } // Connection string for consumer
		public string ApplicationName { get; set; } // Application name for differentiating scopes of queues
		public QueueListeningMode Mode { get; set; } // OnePerApp or OnePerInstance mode for consumers
		public int ConnectRetriesCount { get; set; } = 3; // Number of retries to connect to RabbitMQ
		public int ConnectRetryDelayMs { get; set; } = 2000; // Delay between retries

		public abstract void LogExceptionsTo(Action<Exception, string> action); // Log exceptions to action
		public abstract void LogTo(Action<string> action); // Log debug messages to action
		public void AddFromProfile(BrokerProfile profile); // Add configuration from profile class
		public void AddFromProfiles(); // Add configuration from all profiles via reflection
		public abstract void AddConsumer<mC, M>() // Add consumer
			where mC : BasicAsyncConsumer<M>
			where M : BasicMessage;
		public abstract void AddMessageProcessingLogger<T>() // Add message processing logger that invokes on message processing
			where T : class, IMessageProcessingLogger;
	
	public enum QueueListeningMode
	{
		OnePerApp,
		OnePerInstance
	}
}