first commit

Author: Paul HAMADOU

ApiConsumerProduct/src/ApiConsumerProduct/ApiConsumerProduct.WebApi.xml

@@ -7,9 +7,12 @@ namespace ApiConsumerProduct.Domain.DomainDirectory.Features;
 public sealed class  CreatedProductConsumer() : IConsumer<ICreatedProductMessage>
 {
     public Task Consume(ConsumeContext<ICreatedProductMessage> context)
-    {
-        // do work here
-
-        return Task.CompletedTask;
+    {
+		// do work here
+		var product = context.Message;
+		
+		Console.WriteLine($"Received CreatedProductMessage: ProductId={product.ProductId}, Price={product.Price}, Description={product.Description}, Quantity={product.Quantity}");
+
+		return Task.CompletedTask;
     }
 }

ApiConsumerProduct/src/ApiConsumerProduct/Domain/DomainDirectory/Features/ CreatedProductConsumer.cs

@@ -9,20 +9,20 @@ public static class CreatedProductCusumerEndpointRegistrationRegistration
 {
     public static void CreatedProductCusumerEndpointRegistration(this IRabbitMqBusFactoryConfigurator cfg, IBusRegistrationContext context)
     {
-        cfg.ReceiveEndpoint("created-generation-product-queue", re =>
+        cfg.ReceiveEndpoint(Environment.GetEnvironmentVariable("RMQ_QUEUE_NAME"), re =>
         {
             // turns off default fanout settings
             re.ConfigureConsumeTopology = false;
 
             // a replicated queue to provide high availability and data safety. available in RMQ 3.8+
-            re.SetQuorumQueue();
+          //  re.SetQuorumQueue();
 
             // enables a lazy queue for more stable cluster with better predictive performance.
             // Please note that you should disable lazy queues if you require really high performance, if the queues are always short, or if you have set a max-length policy.
             re.SetQueueArgument("declare", "lazy");
 
             // the consumers that are subscribed to the endpoint
-            re.ConfigureConsumer< CreatedProductConsumer>(context);
+            re.ConfigureConsumer<CreatedProductConsumer>(context);
 
             // the binding of the intermediary exchange and the primary exchange
             re.Bind("created-generation-product-exchange", e =>

ApiConsumerProduct/src/ApiConsumerProduct/Extensions/Services/ConsumerRegistrations/CreatedProductCusumerEndpointRegistrationRegistration.cs

@@ -21,8 +21,8 @@ public static void AddInfrastructure(this IServiceCollection services, IWebHostE
         {
             // this makes local migrations easier to manage. feel free to refactor if desired.
             connectionString = env.IsDevelopment() 
-                ? "Host=localhost;Port=57122;Database=dev_dockerconfig;Username=SA;Password=#localDockerPassword#"
-                : throw new Exception("The database connection string is not set.");
+                ? "Host=localhost;Port=5432;Database=db-consumer-product;Username=postgres;Password=admin"
+				: throw new Exception("The database connection string is not set.");
         }
 
         services.AddDbContext<ConsumerProductDbContext>(options =>

ApiConsumerProduct/src/ApiConsumerProduct/Extensions/Services/InfrastructureServiceExtension.cs

@@ -26,19 +26,19 @@ public static void AddMassTransitServices(this IServiceCollection services, IWeb
                 mt.AddConsumers(Assembly.GetExecutingAssembly());
                 mt.UsingRabbitMq((context, cfg) =>
                 {
-                    cfg.Host(rmqOptions.Host, 
-                        ushort.Parse(rmqOptions.Port), 
-                        rmqOptions.VirtualHost, 
-                        h =>
-                        {
-                            h.Username(rmqOptions.Username);
-                            h.Password(rmqOptions.Password);
-                        });
+					cfg.Host(Environment.GetEnvironmentVariable("RMQ_HOST"),
+					   ushort.Parse(Environment.GetEnvironmentVariable("RMQ_PORT")),
+					   Environment.GetEnvironmentVariable("RMQ_VIRTUAL_HOST"),
+					   h =>
+					   {
+						   h.Username(Environment.GetEnvironmentVariable("RMQ_USERNAME"));
+						   h.Password(Environment.GetEnvironmentVariable("RMQ_PASSWORD"));
+					   });
 
-                    // Producers -- Do Not Delete This Comment
+					// Producers -- Do Not Delete This Comment
 
-                    // Consumers -- Do Not Delete This Comment
-                    cfg.CreatedProductCusumerEndpointRegistration(context);
+					// Consumers -- Do Not Delete This Comment
+					cfg.CreatedProductCusumerEndpointRegistration(context);
                 });
             });
             services.AddOptions<MassTransitHostOptions>();