SmartTender.MessageBroker.NetFramework 1.0.3

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 void AddSmartMessageBroker(this NinjectModule services, string connectionString, Action<BrokerConfig> configureRecievers = null, string customAppName = null);

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

DI Registration Examples

Run consumers in startup.cs

		private void configureWebApi(IAppBuilder app)
		{
			var modules = new INinjectModule[]
			{
				new NinjectRegistrations(),
				new ProZorroSaleModules.DalModule(),
				new ProZorroSaleModules.ApiModule(),
				new ProZorroSaleModules.AppModule(),
				new ProZorroSaleModules.ReportingDalModule(),
				new ProZorroSaleModules.DalElasticModule(),
				new ProZorroSaleModules.DalNewDbModule(),
				new ProZorroSaleModules.ReportingModule(),
				new HangfireNinjectModule(),
				new WebApiNinjectRegistrations()
			};
			var settings = new NinjectSettings
			{
				InjectNonPublic = true,
			};
			var kernel = new StandardKernel(settings, modules);
			var config = new HttpConfiguration
			{
				DependencyResolver = new WebApiNinjectDependencyResolver(kernel),
				IncludeErrorDetailPolicy = IncludeErrorDetailPolicy.Always
			};
			config.Formatters.Remove(config.Formatters.JsonFormatter);
			config.Formatters.Insert(0, new SanitizingJsonMediaTypeFormatter());
			config.Formatters.JsonFormatter.SerializerSettings = new JsonSerializerSettings { NullValueHandling = NullValueHandling.Ignore };
			//config.MessageHandlers.Add(new LanguageMessageHandlerWebApi());
			config.MessageHandlers.Add(new LogWebApiHandler());
			config.MessageHandlers.Add(new ProZorroSaleApiLogHandler());
			config.MapHttpAttributeRoutes();
			config.Filters.Add(new ApiFilterAttribute());
			config.Filters.Add(new GlobalApiFilterAttribute());
			app.UseWebApi(config);
			ProzorroSaleSwaggerConfig.Register(config);
			runProZorroSaleSockets(kernel);
			kernel.UseSmartMessageBrokerConsumers();
			//configureWebApiThrottling(config);
		}

Run consumers in startup.cs

public class NinjectRegistrations : NinjectModule
{
	public override void Load()
	{
		//....
		this.AddSmartMessageBroker("amqps://your-rabbitmq-url", 
			x =>
			{
				x.AddCommonQueueAsyncConsumer<FeatureUsingMessageConsumer, FeatureUsingMessage>();
			}, customAppName: "WebTender");
	}
}

Replace "amqps://your-rabbitmq-url" with your actual RabbitMQ connection string.