some fix

pagopa · Nov 30, 2023 · 9a267b9 · 9a267b9
1 parent f5ef17a
commit 9a267b9
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 3 deletions.
diff --git a/config/application.properties b/config/application.properties
@@ -1,2 +1,2 @@
 aws.profile=default
-
+aws.region=eu-south-1
diff --git a/src/main/java/it/pagopa/interop/signalhub/persister/config/AwsBeanBuilder.java b/src/main/java/it/pagopa/interop/signalhub/persister/config/AwsBeanBuilder.java
@@ -36,7 +36,7 @@ public SqsMessageListenerContainerFactory<Object> defaultSqsListenerContainerFac
         return SqsMessageListenerContainerFactory
                 .builder()
                 .configure(options -> options
-                        //.acknowledgementMode(AcknowledgementMode.ON_SUCCESS)
+                        .acknowledgementMode(AcknowledgementMode.ON_SUCCESS)
                         .maxConcurrentMessages(10)
                         .maxMessagesPerPoll(10))
                 .sqsAsyncClient(sqsAsyncClient())

diff --git a/src/main/java/it/pagopa/interop/signalhub/persister/queue/consumer/SqsInternalListener.java b/src/main/java/it/pagopa/interop/signalhub/persister/queue/consumer/SqsInternalListener.java
@@ -37,7 +37,9 @@ public CompletableFuture<Void> pullFromAwsInternalQueue(@Payload String node, @H
                 .doOnNext(json -> log.info("payloadBody: {}, headers: {}, PullFromInternalQueue received input", node, headers))
                 .map(json -> Utility.jsonToObject(node, SignalEvent.class))
                 .map(signalEvent -> signalMapper.signalEventToSignal(signalEvent, correlationId))
-                .flatMap(signalService::signalServiceFlow)
+                .flatMap(signalEvent -> signalService.signalServiceFlow(signalEvent)
+                        .contextWrite(Context.of(TRACE_ID_KEY, correlationId))
+                )
                 .then()
                 .toFuture();
     }