From bce1d4d7f3b52d057aedfad625ca3a9d47985fc8 Mon Sep 17 00:00:00 2001 From: smirnovaae Date: Mon, 13 Jan 2025 12:57:03 -0800 Subject: [PATCH] wip --- .../java/gov/cms/ab2d/eventlogger/api/EventsListener.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/main/java/gov/cms/ab2d/eventlogger/api/EventsListener.java b/src/main/java/gov/cms/ab2d/eventlogger/api/EventsListener.java index cf8805d..3cab2ef 100644 --- a/src/main/java/gov/cms/ab2d/eventlogger/api/EventsListener.java +++ b/src/main/java/gov/cms/ab2d/eventlogger/api/EventsListener.java @@ -12,6 +12,7 @@ import io.awspring.cloud.sqs.annotation.SqsListener; import lombok.extern.slf4j.Slf4j; import org.springframework.context.annotation.DependsOn; +import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; import static io.awspring.cloud.sqs.annotation.SqsListenerAcknowledgementMode.ON_SUCCESS; @@ -26,7 +27,8 @@ public EventsListener(LogManager logManager) { this.logManager = logManager; } - @SqsListener(value = "${sqs.queue-name}", acknowledgementMode = ON_SUCCESS) + @SqsListener(value = "${sqs.queue-name}")//, acknowledgementMode = ON_SUCCESS) + @Async public void processEvents(SQSMessages sqsMessage) { log.info("EventsListener: Processing events from SQS: " + sqsMessage.getClass().getSimpleName()); switch (sqsMessage.getClass().getSimpleName()) {