chore: fix sonar issue with interrupt

idealo · Jun 21, 2023 · 5610249 · 5610249
1 parent 938f3d9
commit 5610249
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/src/main/java/de/idealo/spring/stream/binder/sqs/health/SqsBinderHealthIndicator.java b/src/main/java/de/idealo/spring/stream/binder/sqs/health/SqsBinderHealthIndicator.java
@@ -2,6 +2,7 @@
 
 import java.net.URI;
 import java.net.URISyntaxException;
+import java.util.concurrent.ExecutionException;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -78,9 +79,12 @@ private boolean isReachable(String queueName) {
         } catch (SdkClientException e) {
             LOGGER.error("Queue '{}' is not reachable", queueName, e);
             return false;
-        } catch (Exception e) {
+        } catch (ExecutionException e) {
             LOGGER.error("Health check failed for queue '{}'", queueName, e);
             return false;
+        } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
+            return false;
         }
     }
 

diff --git a/src/test/resources/logback-test.xml b/src/test/resources/logback-test.xml
@@ -12,6 +12,7 @@
     </appender>
 
     <logger name="de.idealo.spring.stream.binder.sqs" level="debug"/>
+    <logger name="io.awspring.cloud.sqs.listener.source" level="off"/>
 
     <root level="warn">
         <appender-ref ref="STDOUT" />