From fc6fd92ff65b30b35b31eea48bde0357b494cdf3 Mon Sep 17 00:00:00 2001 From: emalfroy Date: Fri, 17 Jan 2025 09:49:50 +0100 Subject: [PATCH] fix: configure kbo sync url --- .../Extensions/WolverineExtensions.cs | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) diff --git a/src/AssociationRegistry.Admin.Api/Infrastructure/Extensions/WolverineExtensions.cs b/src/AssociationRegistry.Admin.Api/Infrastructure/Extensions/WolverineExtensions.cs index 19d7cfe7a..bf0d00102 100644 --- 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() + .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 =>