fix: ajustes em geral principalmente na configuração do MassTransit para todos os contextos limitados

Author: HaraHeique

src-masstransit/PAC.Producao/Consumidores/FuncionarioProducaoRegistradoConsumidor.cs renamed to src-masstransit/PAC.Producao/Consumidores/FuncionarioRegistradoConsumidor.cs

@@ -5,10 +5,10 @@
 
 namespace PAC.Producao.Consumidores
 {
-    public class FuncionarioProducaoRegistradoConsumidor : OperariosConsumidor, IConsumer<FuncionarioProducaoRegistradoMensagem>
+    public class FuncionarioRegistradoConsumidor : OperariosConsumidor, IConsumer<FuncionarioProducaoRegistradoMensagem>
     {
-        public FuncionarioProducaoRegistradoConsumidor(
-            ILogger<FuncionarioProducaoRegistradoConsumidor> logger,
+        public FuncionarioRegistradoConsumidor(
+            ILogger<FuncionarioRegistradoConsumidor> logger,
             ProducaoContext producaoContext) : base(logger, producaoContext) { }
 
         public async Task Consume(ConsumeContext<FuncionarioProducaoRegistradoMensagem> context)

src-masstransit/PAC.Producao/Consumidores/OperariosConsumidor.cs

@@ -6,7 +6,7 @@
 
 namespace PAC.Producao.Consumidores
 {
-    public abstract class OperariosConsumidor
+    public class OperariosConsumidor
     {
         protected readonly ILogger<OperariosConsumidor> _logger;
         protected readonly ProducaoContext _contexto;

src-masstransit/PAC.Producao/Jobs/OperarioEventosIntegracaoJob.cs

@@ -42,8 +42,7 @@ private async Task PublicarMensagem()
 
             LogarInformacoesMensagemConsumida(mensagem);
 
-            // CAP usa Outbox pattern, ou seja, garante sempre o envio da mensagem para o broker e usa políticas de retry caso ocorram falhas (olhar na docs)
-            await _produtor.Publish(mensagem);
+            await _produtor.Publish(mensagem, mensagem.GetType());
 
             RemoverProximaMensagem();
         }

src-masstransit/PAC.Producao/Program.cs

@@ -36,13 +36,20 @@ static void ConfigureServices(WebApplicationBuilder builder)
     builder.Services.AddTransient<OperariosConsumidor>();
 
     // MassTransit - Event bus
-    builder.Services.AddMassTransit(options =>
+    builder.Services.AddMassTransit(config =>
     {
-        options.AddConsumer<FuncionarioAtualizadoConsumidor>(typeof(FuncionarioAtualizadoMensagem));
-        options.AddConsumer<FuncionarioDesligadoConsumidor>(typeof(FuncionarioDesligadoMensagem));
-        options.AddConsumer<FuncionarioProducaoRegistradoConsumidor>(typeof(FuncionarioProducaoRegistradoMensagem));
+        config.AddConsumer<FuncionarioAtualizadoConsumidor>();
+        config.AddConsumer<FuncionarioDesligadoConsumidor>();
+        config.AddConsumer<FuncionarioRegistradoConsumidor>();
 
-        options.UsingRabbitMq();
+        config.UsingRabbitMq((context, cfg) =>
+        {
+            var eventBusSection = builder.Configuration.GetSection("EventBus:Topics");
+
+            cfg.ReceiveEndpoint(eventBusSection["FuncionarioAtualizado"], e => e.ConfigureConsumer<FuncionarioAtualizadoConsumidor>(context));
+            cfg.ReceiveEndpoint(eventBusSection["FuncionarioRegistrado"], e => e.ConfigureConsumer<FuncionarioRegistradoConsumidor>(context));
+            cfg.ReceiveEndpoint(eventBusSection.GetValue<string>("FuncionarioDesligado"), e => e.ConfigureConsumer<FuncionarioDesligadoConsumidor>(context));
+        });
     });
 
     builder.Services.AddOptions<MassTransitHostOptions>()

src-masstransit/PAC.RH/Consumidores/FuncionariosConsumidor.cs

@@ -5,7 +5,7 @@
 
 namespace PAC.RH.Consumidores
 {
-    public abstract class FuncionariosConsumidor
+    public class FuncionariosConsumidor
     {
         protected readonly ILogger<FuncionariosConsumidor> _logger;
         protected readonly RhContext _contexto;

src-masstransit/PAC.RH/Jobs/FuncionarioEventosIntegracaoJob.cs

@@ -43,8 +43,7 @@ private async Task PublicarMensagem()
 
             _logger.LogInformation("Mensagem - {@tipo}: {@mensagem}", mensagem.GetType().Name, JsonConvert.SerializeObject(mensagem));
 
-            // CAP usa Outbox pattern, ou seja, garante sempre o envio da mensagem para o broker e usa políticas de retry caso ocorram falhas (olhar na docs)
-            await _produtor.Publish(mensagem);
+            await _produtor.Publish(mensagem, mensagem.GetType());
 
             RemoverProximaMensagem(_filaProcessos);
         }

src-masstransit/PAC.RH/Program.cs

@@ -58,12 +58,18 @@ static void ConfigureServices(WebApplicationBuilder builder)
     builder.Services.AddHangfireServer();
 
     // MassTransit - Event bus
-    builder.Services.AddMassTransit(options =>
+    builder.Services.AddMassTransit(config =>
     {
-        options.AddConsumer<OperarioNomeAlteradoConsumidor>(typeof(OperarioNomeAlteradoMensagem));
-        options.AddConsumer<VendedorInfoPessoaisAlteradaConsumidor>(typeof(VendedorInfoPessoaisAlteradaMensagem));
+        config.AddConsumer<OperarioNomeAlteradoConsumidor>();
+        config.AddConsumer<VendedorInfoPessoaisAlteradaConsumidor>();
 
-        options.UsingRabbitMq();
+        config.UsingRabbitMq((context, cfg) =>
+        {
+            var eventBusSection = builder.Configuration.GetSection("EventBus:Topics");
+
+            cfg.ReceiveEndpoint(eventBusSection["OperarioNomeAlterado"], e => e.ConfigureConsumer<OperarioNomeAlteradoConsumidor>(context));
+            cfg.ReceiveEndpoint(eventBusSection["VendedorInfoPessoaisAlterado"], e => e.ConfigureConsumer<VendedorInfoPessoaisAlteradaConsumidor>(context));
+        });
     });
 
     builder.Services.AddOptions<MassTransitHostOptions>()

src-masstransit/PAC.Vendas/Consumidores/VendedoresConsumidor.cs

@@ -6,7 +6,7 @@
 
 namespace PAC.Vendas.Consumidores
 {
-    public abstract class VendedoresConsumidor
+    public class VendedoresConsumidor
     {
         protected readonly ILogger<VendedoresConsumidor> _logger;
         protected readonly VendasContext _contexto;

src-masstransit/PAC.Vendas/Jobs/VendedorEventosIntegracaoJob.cs

@@ -41,7 +41,7 @@ private async Task PublicarMensagem()
 
             LogarInformacoesMensagemConsumida(mensagem);
 
-            await _produtor.Publish(mensagem);
+            await _produtor.Publish(mensagem, mensagem.GetType());
 
             RemoverProximaMensagem();
         }

src-masstransit/PAC.Vendas/Program.cs

@@ -38,13 +38,20 @@ static void ConfigureServices(WebApplicationBuilder builder)
     builder.Services.AddTransient<VendedorEventosIntegracaoJob>();
 
     // MassTransit - Event bus
-    builder.Services.AddMassTransit(options =>
+    builder.Services.AddMassTransit(config =>
     {
-        options.AddConsumer<FuncionarioAtualizadoConsumidor>(typeof(FuncionarioAtualizadoMensagem));
-        options.AddConsumer<FuncionarioDesligadoConsumidor>(typeof(FuncionarioDesligadoMensagem));
-        options.AddConsumer<FuncionarioRegistradoConsumidor>(typeof(FuncionarioVendasRegistradoMensagem));
+        config.AddConsumer<FuncionarioAtualizadoConsumidor>();
+        config.AddConsumer<FuncionarioDesligadoConsumidor>();
+        config.AddConsumer<FuncionarioRegistradoConsumidor>();
 
-        options.UsingRabbitMq();
+        config.UsingRabbitMq((context, cfg) =>
+        {
+            var eventBusSection = builder.Configuration.GetSection("EventBus:Topics");
+
+            cfg.ReceiveEndpoint(eventBusSection["FuncionarioAtualizado"], e => e.ConfigureConsumer<FuncionarioAtualizadoConsumidor>(context));
+            cfg.ReceiveEndpoint(eventBusSection["FuncionarioRegistrado"], e => e.ConfigureConsumer<FuncionarioRegistradoConsumidor>(context));
+            cfg.ReceiveEndpoint(eventBusSection.GetValue<string>("FuncionarioDesligado"), e => e.ConfigureConsumer<FuncionarioDesligadoConsumidor>(context));
+        });
     });
 
     builder.Services.AddOptions<MassTransitHostOptions>()