fix: configure kbo sync url

Informatievlaanderen · Jan 17, 2025 · fc6fd92 · fc6fd92
1 parent 1b4ebd7
commit fc6fd92
Showing 1 changed file with 16 additions and 0 deletions.
diff --git a/src/AssociationRegistry.Admin.Api/Infrastructure/Extensions/WolverineExtensions.cs b/src/AssociationRegistry.Admin.Api/Infrastructure/Extensions/WolverineExtensions.cs
@@ -6,6 +6,7 @@
 using Grar.AddressMatch;
 using Hosts.Configuration;
 using JasperFx.CodeGeneration;
+using Kbo;
 using Serilog;
 using Vereniging;
 using Wolverine;
@@ -48,6 +49,8 @@ public static void AddWolverine(this WebApplicationBuilder builder)
                 if (grarOptions.Sqs.UseLocalStack)
                     transportConfiguration.Credentials(new BasicAWSCredentials(accessKey: "dummy", secretKey: "dummy"));
 
+                ConfigureKboSyncQueuePublisher(options, context.Configuration["KboSyncQueueUrl"]);
+
                 ConfigureAddressMatchPublisher(options, grarOptions.Sqs.AddressMatchQueueName);
 
                 ConfiguredAddressMatchListener(options, grarOptions.Sqs.AddressMatchQueueName,
@@ -73,6 +76,19 @@ private static void ConfigureAddressMatchPublisher(WolverineOptions options, str
                .MessageBatchSize(1);
     }
 
+    private static void ConfigureKboSyncQueuePublisher(WolverineOptions options, string sqsQueueName)
+    {
+        options.PublishMessage<TeSynchroniserenKboNummerMessage>()
+               .ToSqsQueue(sqsQueueName)
+               .MessageBatchSize(1);
+
+        options.ListenToSqsQueue(sqsQueueName, configure: configure =>
+                {
+                    configure.MaxNumberOfMessages = 1;
+                })
+               .MaximumParallelMessages(1);
+    }
+
     private static void ConfiguredAddressMatchListener(WolverineOptions options, string sqsQueueName, string sqsDeadLetterQueueName)
     {
         options.ListenToSqsQueue(sqsQueueName, configure: configure =>