elias/booking-microservices
1
0
Fork 0
mirror of https://github.com/meysamhadeli/booking-microservices.git synced 2026-04-28 00:20:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor: Refactor and remove unnecessary code in masstransit base

Browse Source
This commit is contained in:
Pc 2023-05-14 22:06:04 +03:30
parent ad174d1be8
commit c6eff3a8b6
1 changed files with 6 additions and 46 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
src/BuildingBlocks/MassTransit/Extensions.cs
View File

@ -37,65 +37,27 @@ public static class Extensions
IBusRegistrationConfigurator configure, Assembly assembly) IBusRegistrationConfigurator configure, Assembly assembly)
{ {
configure.AddConsumers(assembly); configure.AddConsumers(assembly);
configure.AddSagaStateMachines(assembly);
configure.AddSagas(assembly);
configure.AddActivities(assembly);
configure.UsingRabbitMq((context, configurator) => configure.UsingRabbitMq((context, configurator) =>
{ {
var rabbitMqOptions = services.GetOptions<RabbitMqOptions>(nameof(RabbitMqOptions)); var rabbitMqOptions = services.GetOptions<RabbitMqOptions>(nameof(RabbitMqOptions));
configurator.Host(rabbitMqOptions?.HostName, rabbitMqOptions?.Port ?? 5672, "/", h => configurator.Host(rabbitMqOptions?.HostName, rabbitMqOptions?.Port ?? 5672, "/", h =>
{ {
h.Username(rabbitMqOptions?.UserName); h.Username(rabbitMqOptions?.UserName);
h.Password(rabbitMqOptions?.Password); h.Password(rabbitMqOptions?.Password);
}); });
configurator.ConfigureEndpoints(context);
var integrationEventRootAssemblies = Assembly.GetAssembly(typeof(IIntegrationEvent)); configurator.UseMessageRetry(AddRetryConfiguration);
var types = integrationEventRootAssemblies?.GetTypes()
.Where(x => x.IsAssignableTo(typeof(IIntegrationEvent))
&& !x.IsInterface
&& !x.IsAbstract
&& !x.IsGenericType)?.ToList();
if (types != null && types.Any())
{
foreach (var type in types)
{
var consumers = assembly?.GetTypes()
.Where(x => x.IsAssignableTo(typeof(IConsumer<>).MakeGenericType(type))).ToList();
if (consumers != null && consumers.Any())
configurator.ReceiveEndpoint(
string.IsNullOrEmpty(rabbitMqOptions.ExchangeName)
? type.Name.Underscore()
: $"{rabbitMqOptions.ExchangeName}_{type.Name.Underscore()}", e =>
{
e.UseConsumeFilter(typeof(ConsumeFilter<>), context); //generic filter
foreach (var consumer in consumers)
{
//ref: https://masstransit-project.com/usage/exceptions.html#retry
//ref: https://markgossa.com/2022/06/masstransit-exponential-back-off.html
configurator.UseMessageRetry(r => AddRetryConfiguration(r));
configurator.ConfigureEndpoints(context, x => x.Exclude(consumer));
var methodInfo = typeof(DependencyInjectionReceiveEndpointExtensions)
.GetMethods()
.Where(x => x.GetParameters()
.Any(p => p.ParameterType == typeof(IServiceProvider)))
.FirstOrDefault(x => x.Name == "Consumer" && x.IsGenericMethod);
var generic = methodInfo?.MakeGenericMethod(consumer);
generic?.Invoke(e, new object[] { e, context, null });
}
});
}
}
}); });
} }
private static IRetryConfigurator AddRetryConfiguration(IRetryConfigurator retryConfigurator) private static void AddRetryConfiguration(IRetryConfigurator retryConfigurator)
{ {
retryConfigurator.Exponential( retryConfigurator.Exponential(
3, 3,
@ -103,7 +65,5 @@ public static class Extensions
TimeSpan.FromMinutes(120), TimeSpan.FromMinutes(120),
TimeSpan.FromMilliseconds(200)) TimeSpan.FromMilliseconds(200))
.Ignore<ValidationException>(); // don't retry if we have invalid data and message goes to _error queue masstransit .Ignore<ValidationException>(); // don't retry if we have invalid data and message goes to _error queue masstransit
return retryConfigurator;
} }
} }