ITD-103333: add region to local aws commands

CHANGELOG.md

@@ -1,3 +1,7 @@
+# 0.8.0
+
+* pass MDC context to workers
+
 # 0.7.1
 
 * adds the possibility to configure a handling in case of a `Throwable` in `ErrorHandlingStrategy`

pom.xml

@@ -4,7 +4,7 @@
  <artifactId>sqs-utils</artifactId>
  <groupId>com.mercateo.sqs</groupId>
  <name>sqs-utils</name>
- <version>0.7.5-SNAPSHOT</version>
+ <version>0.8.0-SNAPSHOT</version>
  <packaging>jar</packaging>
 
  <description>Some utility classes for AWS SQS</description>

src/main/java/com/mercateo/sqs/utils/message/handling/LongRunningMessageHandler.java

@@ -20,6 +20,8 @@
 import com.mercateo.sqs.utils.visibility.VisibilityTimeoutExtenderFactory;
 
 import java.time.Duration;
+import java.util.Map;
+import java.util.concurrent.Future;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.ScheduledFuture;
 import java.util.concurrent.TimeUnit;
@@ -28,6 +30,7 @@
 import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
 
+import org.slf4j.MDC;
 import org.springframework.messaging.Message;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 
@@ -79,7 +82,16 @@ public class LongRunningMessageHandler<I, O> {
  this.awaitShutDown = awaitShutDown;
  this.errorHandlingStrategy = errorHandlingStrategy;
 
- messageProcessingExecutor = new ThreadPoolTaskExecutor();
+ messageProcessingExecutor = new ThreadPoolTaskExecutor() {
+ @Override
+ public Future<?> submit(Runnable task) {
+ Map<String, String> current = MDC.getCopyOfContextMap();
+ return super.submit(() -> {
+ MDC.setContextMap(current);
+ task.run();
+ });
+ }
+ };
  messageProcessingExecutor.setCorePoolSize(numberOfThreads);
  messageProcessingExecutor.setMaxPoolSize(numberOfThreads);
  messageProcessingExecutor.setThreadNamePrefix(getClass().getSimpleName()+"-"+queue.getName().getId()+"-");